app/main.py

@@ -38,6 +38,9 @@ async def lifespan(app: FastAPI):
 
     from apscheduler.schedulers.asyncio import AsyncIOScheduler
     from apscheduler.triggers.cron import CronTrigger
+    from zoneinfo import ZoneInfo
+
+    KST = ZoneInfo("Asia/Seoul")
     from services.search.query_analyzer import prewarm_analyzer
     from workers.briefing_worker import run as morning_briefing_run
     from workers.daily_digest import run as daily_digest_run
@@ -90,12 +93,12 @@ async def lifespan(app: FastAPI):
     # safety > law > manual 우선순위로 25건씩. 6720 레거시 → 야간당 ~150건 → 약 45일 소화.
     scheduler.add_job(tier_backfill_run, "interval", minutes=30, id="tier_backfill")
     # 일일 스케줄 (KST)
-    scheduler.add_job(law_monitor_run, CronTrigger(hour=7), id="law_monitor")
-    scheduler.add_job(mailplus_run, CronTrigger(hour=7), id="mailplus_morning")
-    scheduler.add_job(mailplus_run, CronTrigger(hour=18), id="mailplus_evening")
-    scheduler.add_job(daily_digest_run, CronTrigger(hour=20), id="daily_digest")
-    scheduler.add_job(global_digest_run, CronTrigger(hour=4, minute=0), id="global_digest")
-    scheduler.add_job(morning_briefing_run, CronTrigger(hour=5, minute=10), id="morning_briefing")
+    scheduler.add_job(law_monitor_run, CronTrigger(hour=7, timezone=KST), id="law_monitor")
+    scheduler.add_job(mailplus_run, CronTrigger(hour=7, timezone=KST), id="mailplus_morning")
+    scheduler.add_job(mailplus_run, CronTrigger(hour=18, timezone=KST), id="mailplus_evening")
+    scheduler.add_job(daily_digest_run, CronTrigger(hour=20, timezone=KST), id="daily_digest")
+    scheduler.add_job(global_digest_run, CronTrigger(hour=4, minute=0, timezone=KST), id="global_digest")
+    scheduler.add_job(morning_briefing_run, CronTrigger(hour=5, minute=10, timezone=KST), id="morning_briefing")
     scheduler.add_job(news_collector_run, "interval", hours=6, id="news_collector")
     scheduler.start()
 

app/workers/daily_digest.py

@@ -6,6 +6,7 @@ DEVONthink/OmniFocus → PostgreSQL/CalDAV 쿼리로 전환.
 
 import os
 from datetime import datetime, timezone
+from zoneinfo import ZoneInfo
 from pathlib import Path
 
 from sqlalchemy import func, select, text
@@ -21,7 +22,8 @@ logger = setup_logger("daily_digest")
 
 async def run():
     """일일 다이제스트 생성 + 저장 + 발송"""
-    today = datetime.now(timezone.utc).strftime("%Y-%m-%d")
+    # KST 기준 오늘 (cron 이 KST timezone fix 후 20:00 KST 에 fire). date 객체로 비교 — Document.created_at::date 와 직접 매칭.
+    today = datetime.now(ZoneInfo("Asia/Seoul")).date()
     sections = []
 
     async with async_session() as session: