pauses

etl_craft.engine.repository.pauses

Paused pipelines, in AUD_PIPELINE_PAUSES.

Pause dataclass

A pipeline's open pause: when, who, and why.

describe

describe() -> str

Return one line saying since when, by whom and why.

fetch_open_pause

fetch_open_pause(conn: Connection, pipeline_id: int) -> Pause | None

Return the open pause of pipeline_id, or None when it is not paused.

fetch_open_pauses

fetch_open_pauses(conn: Connection) -> dict[str, Pause]

Return every paused pipeline's open pause, by pipeline code.

record_pause

record_pause(conn: Connection, pipeline_id: int, paused_by: str, reason: str) -> None

Open a pause of pipeline_id.

close_pause

close_pause(conn: Connection, pipeline_id: int, resumed_by: str, reason: str) -> bool

Close the open pause of pipeline_id; return whether it had one.