aligned.local.job

module documentation
(source)

Undocumented

Class FileDateJob Undocumented
Class FileFactualJob No class docstring; 0/2 property, 0/4 class variable, 1/6 method documented
Class FileFullJob Undocumented
Class LiteralRetrievalJob Undocumented
Async Function aggregate Undocumented
Async Function aggregate_over Undocumented
Function decode_timestamps Undocumented
Variable logger Undocumented
async def aggregate(request: RetrievalRequest, core_data: pl.LazyFrame) -> pl.LazyFrame: (source)

Undocumented

async def aggregate_over(group: AggregateOver, features: set[AggregatedFeature], df: pl.LazyFrame, event_timestamp_col: str, group_by: list[str] | None = None) -> pl.LazyFrame: (source)

Undocumented

def decode_timestamps(df: pl.LazyFrame, request: RetrievalRequest, formatter: DateFormatter) -> pl.LazyFrame: (source)

Undocumented

logger = (source)

Undocumented