gahusb
119ac88e1e
- StockAgent.on_screener_schedule: snapshot/refresh → screener/run(mode=auto) → telegram_payload(MarkdownV2) 발송. skipped_holiday는 무발신, 실패 시 운영자 HTML 알림. - service_proxy: refresh_screener_snapshot, run_stock_screener 추가 (각각 180s timeout, STOCK_LAB_URL 기존 env 재사용). - telegram.messaging.send_raw: parse_mode 파라미터 추가 (기본 HTML 유지, MarkdownV2 페이로드 직접 전달용). - scheduler: cron day_of_week=mon-fri hour=16 minute=30 id=stock_screener (Asia/Seoul TZ). - on_command 'run_screener' 수동 트리거 추가. - tests: 성공/휴일/스냅샷실패/run실패/이상status 5케이스.
64 lines
2.0 KiB
Python
64 lines
2.0 KiB
Python
import asyncio
|
|
from apscheduler.schedulers.asyncio import AsyncIOScheduler
|
|
|
|
from .agents import AGENT_REGISTRY
|
|
|
|
scheduler = AsyncIOScheduler(timezone="Asia/Seoul")
|
|
|
|
async def _check_idle_breaks():
|
|
for agent in AGENT_REGISTRY.values():
|
|
await agent.check_idle_break()
|
|
|
|
async def _run_stock_schedule():
|
|
agent = AGENT_REGISTRY.get("stock")
|
|
if agent:
|
|
await agent.on_schedule()
|
|
|
|
async def _run_stock_screener():
|
|
agent = AGENT_REGISTRY.get("stock")
|
|
if agent:
|
|
await agent.on_screener_schedule()
|
|
|
|
async def _run_blog_schedule():
|
|
agent = AGENT_REGISTRY.get("blog")
|
|
if agent:
|
|
await agent.on_schedule()
|
|
|
|
async def _run_lotto_schedule():
|
|
agent = AGENT_REGISTRY.get("lotto")
|
|
if agent:
|
|
await agent.on_schedule()
|
|
|
|
async def _run_youtube_research():
|
|
agent = AGENT_REGISTRY.get("youtube")
|
|
if agent:
|
|
await agent.on_schedule()
|
|
|
|
async def _send_youtube_weekly_report():
|
|
agent = AGENT_REGISTRY.get("youtube")
|
|
if agent:
|
|
await agent.send_weekly_report()
|
|
|
|
async def _poll_pipelines():
|
|
agent = AGENT_REGISTRY.get("youtube_publisher")
|
|
if agent:
|
|
await agent.poll_state_changes()
|
|
|
|
def init_scheduler():
|
|
scheduler.add_job(_run_stock_schedule, "cron", hour=7, minute=30, id="stock_news")
|
|
scheduler.add_job(
|
|
_run_stock_screener,
|
|
"cron",
|
|
day_of_week="mon-fri",
|
|
hour=16,
|
|
minute=30,
|
|
id="stock_screener",
|
|
)
|
|
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_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(_check_idle_breaks, "interval", seconds=60, id="idle_check")
|
|
scheduler.add_job(_poll_pipelines, "interval", seconds=30, id="pipeline_poll")
|
|
scheduler.start()
|