results

etl_craft.services.operations.results ¶

Build post-operation views from exact execution identities.

prepare_execution ¶

prepare_execution(ctx: OperationContext, pipeline_code: str) -> int

Reconcile expired owners before dispatch, without adopting them.

selected_date ¶

selected_date(ctx: OperationContext, pipeline_id: int, selector: RunSelector, run_date: date | None) -> RunSelector

Pin an existing run before checking its immutable logical date.

result ¶

result(ctx: OperationContext, pipeline_code: str, status: RunStatus, message: str, *, pipeline_run_id: int | None = None, task_run_id: int | None = None, task_code: str | None = None, pipeline_id: int | None = None, waiting: bool = False) -> OperationResult

Read one consistent result; a task's returned id determines its pipeline run.