reconcile

etl_craft.execution.reconcile

Reconcile expired owners without reviving leases or adopting unrelated processes.

Reconciliation dataclass

Attempts lost and supervisors released by this reconciliation call.

stop_process

stop_process(pid: int, birth: str, *, grace_seconds: float = 10) -> None

Stop a verified child group; recheck its birth identity before each signal.

reconcile

reconcile(engine: Engine, *, pipeline_id: int | None = None, task_id: int | None = None) -> Reconciliation

Fence expired attempts, stop verified local children, then release expired idle runs.