feat(agent-office): cron mon-fri 08:00 ai_news sentiment job
This commit is contained in:
@@ -19,6 +19,11 @@ async def _run_stock_screener():
|
|||||||
if agent:
|
if agent:
|
||||||
await agent.on_screener_schedule()
|
await agent.on_screener_schedule()
|
||||||
|
|
||||||
|
async def _run_stock_ai_news():
|
||||||
|
agent = AGENT_REGISTRY.get("stock")
|
||||||
|
if agent:
|
||||||
|
await agent.on_ai_news_schedule()
|
||||||
|
|
||||||
async def _run_blog_schedule():
|
async def _run_blog_schedule():
|
||||||
agent = AGENT_REGISTRY.get("blog")
|
agent = AGENT_REGISTRY.get("blog")
|
||||||
if agent:
|
if agent:
|
||||||
@@ -54,6 +59,14 @@ def init_scheduler():
|
|||||||
minute=30,
|
minute=30,
|
||||||
id="stock_screener",
|
id="stock_screener",
|
||||||
)
|
)
|
||||||
|
scheduler.add_job(
|
||||||
|
_run_stock_ai_news,
|
||||||
|
"cron",
|
||||||
|
day_of_week="mon-fri",
|
||||||
|
hour=8,
|
||||||
|
minute=0,
|
||||||
|
id="stock_ai_news_sentiment",
|
||||||
|
)
|
||||||
scheduler.add_job(_run_blog_schedule, "cron", hour=10, minute=0, id="blog_pipeline")
|
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=9, minute=0, id="lotto_curate")
|
scheduler.add_job(_run_lotto_schedule, "cron", day_of_week="mon", hour=9, minute=0, id="lotto_curate")
|
||||||
scheduler.add_job(_run_youtube_research, "cron", hour=9, minute=0, id="youtube_research")
|
scheduler.add_job(_run_youtube_research, "cron", hour=9, minute=0, id="youtube_research")
|
||||||
|
|||||||
Reference in New Issue
Block a user