diff --git a/agent-office/app/scheduler.py b/agent-office/app/scheduler.py index 1c6b2d6..7eeacf6 100644 --- a/agent-office/app/scheduler.py +++ b/agent-office/app/scheduler.py @@ -24,9 +24,15 @@ async def _run_blog_schedule(): if agent: await agent.on_schedule() +async def _run_lotto_schedule(): + agent = AGENT_REGISTRY.get("lotto") + if agent: + await agent.on_schedule() + def init_scheduler(): scheduler.add_job(_run_stock_schedule, "cron", hour=7, minute=30, id="stock_news") scheduler.add_job(_run_realestate_schedule, "cron", hour=9, minute=15, id="realestate_report") scheduler.add_job(_run_blog_schedule, "cron", hour=10, minute=0, id="blog_pipeline") + scheduler.add_job(_run_lotto_schedule, "cron", day_of_week="mon", hour=7, minute=0, id="lotto_curate") scheduler.add_job(_check_idle_breaks, "interval", seconds=60, id="idle_check") scheduler.start()