aligned.psql.jobs.FactPsqlJob

class documentation

class FactPsqlJob(RetrievalJob): (source)

Fetches features for defined facts within a postgres DB

It is supported to fetch from different tables, in one request This is hy the source property is a dict with sources

NB: It is expected that the data sources are for the same psql instance

Method	`aggregated_values_from_request`	Undocumented
Method	`build_entities_from_values`	Undocumented
Async Method	`build_request`	Undocumented
Method	`build_request_from_facts`	Undocumented
Method	`build_sql_entity_query`	Undocumented
Method	`describe`	Undocumented
Method	`dtype_to_sql_type`	Undocumented
Method	`generate_query`	Undocumented
Method	`ignore_event_timestamp`	Undocumented
Async Method	`psql_job`	Undocumented
Method	`sql_aggregated_request`	Undocumented
Async Method	`to_lazy_polars`	Undocumented
Async Method	`to_pandas`	Undocumented
Method	`value_selection`	Undocumented
Class Variable	`facts`	Undocumented
Class Variable	`requests`	Undocumented
Class Variable	`sources`	Undocumented
Property	`config`	Undocumented
Property	`request_result`	Undocumented
Property	`retrieval_requests`	Undocumented

Inherited from RetrievalJob:

Static Method	`from_convertable`	Undocumented
Static Method	`from_dict`	Undocumented
Static Method	`from_lazy_function`	Undocumented
Static Method	`from_polars_df`	Undocumented
Method	`aggregate`	Undocumented
Method	`cache_raw_data`	Undocumented
Method	`cached_at`	Undocumented
Method	`chunked`	Undocumented
Method	`combined_features`	Undocumented
Method	`derive_features`	Undocumented
Method	`drop_duplicate_entities`	Undocumented
Method	`drop_invalid`	Drops invalid row based on the defined features.
Method	`ensure_types`	Undocumented
Method	`fill_missing_columns`	Undocumented
Method	`filter`	Filters based on a condition referencing either a feature, a feature name, or an polars expression to filter on.
Method	`inject_store`	Undocumented
Method	`join`	Undocumented
Method	`join_asof`	Undocumented
Method	`limit`	Undocumented
Method	`listen_to_events`	Undocumented
Method	`log_each_job`	Undocumented
Method	`monitor_time_used`	Undocumented
Method	`on_error`	SomeView.query().all().on_error(ValueError, lambda e: pl.DataFrame(...))
Method	`on_load`	Undocumented
Method	`polars_method`	Undocumented
Method	`remove_derived_features`	Undocumented
Method	`rename`	Undocumented
Method	`return_invalid`	Undocumented
Method	`select`	Undocumented
Method	`select_columns`	Undocumented
Method	`split`	Undocumented
Async Method	`to_polars`	Undocumented
Async Method	`to_spark`	Undocumented
Method	`train_test`	Undocumented
Method	`train_test_validate`	Undocumented
Method	`transform_polars`	Undocumented
Method	`unique_entities`	Undocumented
Method	`unique_on`	Undocumented
Method	`unpack_embeddings`	Undocumented
Method	`update_vector_index`	Undocumented
Method	`validate_entites`	Undocumented
Method	`with_request`	Undocumented
Method	`with_subfeatures`	Undocumented
Method	`without_derived_features`	Undocumented
Async Method	`write_to_source`	Writes the output of the retrieval job to the passed source.
Property	`loaded_columns`	Undocumented

def aggregated_values_from_request(self, request: RetrievalRequest) -> list[TableFetch]: (source) ¶

Undocumented

def build_entities_from_values(self, values: list[list[SqlValue]]) -> str: (source) ¶

Undocumented

async def build_request(self) -> str: (source) ¶

Undocumented

def build_request_from_facts(self, facts: pl.LazyFrame) -> str: (source) ¶

Undocumented

def build_sql_entity_query(self, sql_facts: PostgreSqlJob) -> str: (source) ¶

Undocumented

def describe(self) -> str: (source) ¶

overrides aligned.retrieval_job.RetrievalJob.describe

Undocumented

def dtype_to_sql_type(self, dtype: object) -> str: (source) ¶

Undocumented

def generate_query(self, entity_columns: list[str], entity_query: str, tables: list[TableFetch], aggregates: list[TableFetch], final_select: list[str], final_joins: str) -> str: (source) ¶

Undocumented

def ignore_event_timestamp(self) -> RetrievalJob: (source) ¶

overrides aligned.retrieval_job.RetrievalJob.ignore_event_timestamp

Undocumented

async def psql_job(self) -> PostgreSqlJob: (source) ¶

Undocumented

def sql_aggregated_request(self, window: AggregateOver, features: set[AggregatedFeature], request: RetrievalRequest) -> TableFetch: (source) ¶

Undocumented

async def to_lazy_polars(self) -> pl.LazyFrame: (source) ¶

overrides aligned.retrieval_job.RetrievalJob.to_lazy_polars

Undocumented

async def to_pandas(self) -> pd.DataFrame: (source) ¶

overrides aligned.retrieval_job.RetrievalJob.to_pandas

Undocumented