status
etl_craft.services.operations.status ¶
Read execution snapshots and explain them without admitting work or changing history.
DependencyView
dataclass
¶
One dependency's observed state or recorded admission decision.
GateWaitView
dataclass
¶
A persisted wait, including a pipeline gate when task_id is absent.
TaskSnapshot
dataclass
¶
All inputs to a task explanation captured under one database snapshot.
Explanation
dataclass
¶
A task's observed state and the change needed before it can run.
TaskStatusView
dataclass
¶
A configured task's summary and its explanation under the selected run.
StatusView
dataclass
¶
A run's header and every active configured task, including tasks not run.
explain ¶
Explain a captured state with no database calls, clock reads or mutations.
pipeline_status ¶
pipeline_status(ctx: OperationContext, pipeline_code: str, *, selector: RunSelector = runlog.ACTIVE_RUN) -> StatusView
Inspect an exact run; never reconcile or resolve it by recency.
explain_task ¶
explain_task(ctx: OperationContext, pipeline_code: str, task_code: str, *, selector: RunSelector = runlog.ACTIVE_RUN) -> Explanation
Capture the selected task's state and explain it without modifying the run.