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.