Consume fired jobs from cron_queue (called by agent_loop).
()
| 550 | |
| 551 | |
| 552 | def consume_cron_queue() -> list[CronJob]: |
| 553 | """Consume fired jobs from cron_queue (called by agent_loop).""" |
| 554 | with cron_lock: |
| 555 | fired = list(cron_queue) |
| 556 | cron_queue.clear() |
| 557 | return fired |
| 558 | |
| 559 | |
| 560 | # Load durable jobs on startup, then start scheduler thread |