Skip to content

leadership

etl_craft.overseer.leadership

One process owns a deployment through a session lock, never a heartbeat guess.

Leadership dataclass

The held PostgreSQL listener, or SQLite's polling fallback.

wait

wait(stop: Event) -> None

Wake on a committed execution notification or at the one-second poll.

leadership

leadership(engine: Engine) -> Iterator[Leadership]

Hold a deployment-specific lock until all local workers have stopped.