angee.integrate.scheduler

Pure scheduler logic for due integration bridges.

run_due_bridges

def run_due_bridges(*, now: datetime | None = None) -> dict[str, int]

Run every bridge row due at now and return scheduler counters.

Each due row is re-read and claimed under a row lock (Bridge.claim_sync pushes its next_sync_at one interval out) before the shared bridge runner handles locking and lifecycle telemetry. Manual syncs use the same runner through the queued sync_bridge_now task.

enqueue_due_bridges

def enqueue_due_bridges(*, now: datetime | None = None) -> dict[str, int]

Claim every due bridge row and enqueue one sync task for each.