gahusb/web-page-backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(agent-office): register InstaAgent + 09:30 cron job

Browse Source
This commit is contained in:
gahusb
2026-05-16 00:47:28 +09:00
parent 6eb24090ed
commit 9095423026
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
agent-office/app/agents/__init__.py
View File

@@ -1,6 +1,6 @@
from .stock import StockAgent from .stock import StockAgent
from .music import MusicAgent from .music import MusicAgent
from .blog import BlogAgent from .insta import InstaAgent
from .realestate import RealestateAgent from .realestate import RealestateAgent
from .lotto import LottoAgent from .lotto import LottoAgent
from .youtube import YouTubeResearchAgent from .youtube import YouTubeResearchAgent
@@ -11,7 +11,7 @@ AGENT_REGISTRY = {}
def init_agents(): def init_agents():
AGENT_REGISTRY["stock"] = StockAgent() AGENT_REGISTRY["stock"] = StockAgent()
AGENT_REGISTRY["music"] = MusicAgent() AGENT_REGISTRY["music"] = MusicAgent()
AGENT_REGISTRY["blog"] = BlogAgent() AGENT_REGISTRY["insta"] = InstaAgent()
AGENT_REGISTRY["realestate"] = RealestateAgent() AGENT_REGISTRY["realestate"] = RealestateAgent()
AGENT_REGISTRY["lotto"] = LottoAgent() AGENT_REGISTRY["lotto"] = LottoAgent()
AGENT_REGISTRY["youtube"] = YouTubeResearchAgent() AGENT_REGISTRY["youtube"] = YouTubeResearchAgent()

6
agent-office/app/scheduler.py
View File

@@ -24,8 +24,8 @@ async def _run_stock_ai_news():
if agent: if agent:
await agent.on_ai_news_schedule() await agent.on_ai_news_schedule()
async def _run_blog_schedule(): async def _run_insta_schedule():
agent = AGENT_REGISTRY.get("blog") agent = AGENT_REGISTRY.get("insta")
if agent: if agent:
await agent.on_schedule() await agent.on_schedule()
@@ -67,7 +67,7 @@ def init_scheduler():
minute=0, minute=0,
id="stock_ai_news_sentiment", id="stock_ai_news_sentiment",
) )
scheduler.add_job(_run_blog_schedule, "cron", hour=10, minute=0, id="blog_pipeline") scheduler.add_job(_run_insta_schedule, "cron", hour=9, minute=30, id="insta_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")
scheduler.add_job(_send_youtube_weekly_report, "cron", day_of_week="mon", hour=8, minute=0, id="youtube_weekly_report") scheduler.add_job(_send_youtube_weekly_report, "cron", day_of_week="mon", hour=8, minute=0, id="youtube_weekly_report")