schedules

etl_craft.overseer.schedules

Create durable schedule ticks, retaining only each definition's next deadline.

Schedules

Cache one future tick per active definition; history is the restart cursor.

__init__

__init__() -> None

Start with no deadlines until the Engine DB has been read.

refresh

refresh(ctx: OperationContext, now: datetime, stop: Event | None = None) -> None

Record missed ticks and enqueue due work in short transactions.