aligned.CustomMethodDataSource

class documentation

class CustomMethodDataSource(CodableBatchDataSource): (source)

Constructors: CustomMethodDataSource.from_load(method, depends_on, docker_config), CustomMethodDataSource.from_methods(all_data, all_between_dates, features_for, generic_load, depends_on_sources, ...)

View In Hierarchy

Undocumented

Class Method multi_source_features_for Undocumented
Static Method default_throw Undocumented
Static Method from_load Undocumented
Static Method from_methods Undocumented
Method all_between_dates Undocumented
Method all_data Undocumented
Method depends_on Undocumented
Method features_for Undocumented
Method job_group_key A key defining which sources can be grouped together in one request.
Class Variable all_between_dates_method Undocumented
Class Variable all_data_method Undocumented
Class Variable depends_on_sources Undocumented
Class Variable docker_config Undocumented
Class Variable features_for_method Undocumented
Class Variable generic_method Undocumented
Class Variable type_name Undocumented
Property all_method Undocumented
Property as_markdown Undocumented
Property between_method Undocumented
Property for_method Undocumented

Inherited from CodableBatchDataSource:

Class Method _deserialize Undocumented
Method _serialize Undocumented

Inherited from BatchDataSource (via CodableBatchDataSource):

Method __hash__ Undocumented
Method all Undocumented
Method all_columns Undocumented
Async Method feature_view_code Setup the code needed to represent the data source as a feature view
Method filter Undocumented
Async Method freshness .table("my_table") .freshness()
Method location_id Undocumented
Method needed_configs Undocumented
Async Method schema Returns the schema for the data source
Method source_id An id that identifies a source from others.
Method tags Undocumented
Method transform_with_polars Undocumented
Method with_loaded_at Undocumented
Method with_view Undocumented
def multi_source_features_for(cls: type[T], facts: RetrievalJob, requests: list[tuple[T, RetrievalRequest]]) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.multi_source_features_for

Undocumented

def default_throw(*args: Any, **kwargs: Any) -> pl.LazyFrame: (source)

Undocumented

def from_load(method: Callable[[RetrievalRequest], Coroutine[None, None, pl.LazyFrame]], depends_on: set[FeatureLocation] | None = None, docker_config: DockerConfig | None = None) -> CustomMethodDataSource: (source)

Undocumented

def from_methods(all_data: Callable[[RetrievalRequest, (int | None)], Coroutine[None, None, pl.LazyFrame]] | None = None, all_between_dates: Callable[[RetrievalRequest, datetime, datetime], Coroutine[None, None, pl.LazyFrame]] | None = None, features_for: Callable[[RetrievalJob, RetrievalRequest], Coroutine[None, None, pl.LazyFrame]] | None = None, generic_load: Callable[[RetrievalRequest], Coroutine[None, None, pl.LazyFrame]] | None = None, depends_on_sources: set[FeatureLocation] | None = None, docker_config: DockerConfig | str | None = None) -> CustomMethodDataSource: (source)

Undocumented

def all_between_dates(self, request: RetrievalRequest, start_date: datetime, end_date: datetime) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.all_between_dates

Undocumented

def all_data(self, request: RetrievalRequest, limit: int | None) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.all_data

Undocumented

def depends_on(self) -> set[FeatureLocation]: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.depends_on

Undocumented

def features_for(self, facts: RetrievalJob, request: RetrievalRequest) -> RetrievalJob: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.features_for

Undocumented

def job_group_key(self) -> str: (source)
overrides aligned.data_source.batch_data_source.BatchDataSource.job_group_key

A key defining which sources can be grouped together in one request.

all_between_dates_method: CodableFunction | None = (source)

Undocumented

all_data_method: CodableFunction | None = (source)

Undocumented

depends_on_sources: set[FeatureLocation] | None = (source)

Undocumented

docker_config: DockerConfig | None = (source)

Undocumented

features_for_method: CodableFunction | None = (source)

Undocumented

generic_method: CodableFunction | None = (source)

Undocumented

type_name: str = (source)
overrides aligned.data_source.batch_data_source.CodableBatchDataSource.type_name

Undocumented

all_method: Callable[[RetrievalRequest, (int | None)], Coroutine[None, None, pl.LazyFrame]] = (source)

Undocumented

as_markdown: str = (source)
overrides aligned.data_source.batch_data_source.CodableBatchDataSource.as_markdown

Undocumented

between_method: Callable[[RetrievalRequest, datetime, datetime], Coroutine[None, None, pl.LazyFrame]] = (source)

Undocumented

for_method: Callable[[RetrievalJob, RetrievalRequest], Coroutine[None, None, pl.LazyFrame]] = (source)

Undocumented