runs
etl_craft.engine.repository.runs ¶
A pipeline run's tasks and their outcomes.
PENDING
module-attribute
¶
The status reported for a task with no row under the run: it never started.
TaskStatus
dataclass
¶
One active task's outcome under a pipeline run.
LatestPipelineRun
dataclass
¶
A pipeline's most recently started run.
fetch_task_statuses_for_run ¶
fetch_task_statuses_for_run(conn: Connection, pipeline_id: int, pipeline_run_id: int) -> list[TaskStatus]
Return every active task in pipeline_id with its status under pipeline_run_id.
fetch_latest_pipeline_run ¶
Return the most recently started run of pipeline_id, or None if it never ran.