overseers

etl_craft.engine.repository.overseers ¶

Overseer process history and a working set bounded to active runs.

active_overseer(engine: Engine) -> str

Describe the latest unclosed process without treating history as a lock.

start(engine: Engine) -> int

Record a leader only after its session lock has been acquired.

heartbeat(engine: Engine, overseer_id: int, *, stopped: bool = False) -> None

Renew this process's history, optionally recording its clean shutdown.