From 5c89f4d04ae20727864eca7c8f18aff0dde831b9 Mon Sep 17 00:00:00 2001 From: Giorgio Gilestro Date: Mon, 25 May 2026 23:20:06 +0200 Subject: [PATCH] scheduler: register email_digest_job at 06:30 UTC --- app/scheduler_main.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/app/scheduler_main.py b/app/scheduler_main.py index e20d15e..54dec6d 100644 --- a/app/scheduler_main.py +++ b/app/scheduler_main.py @@ -13,7 +13,7 @@ from app.db import get_engine from app.logging import configure_logging, get_logger from app.jobs import ( market_job, news_job, ai_log_job, rollup_job, - indicator_summary_job, universe_flush_job, + indicator_summary_job, universe_flush_job, email_digest_job, ) @@ -58,6 +58,11 @@ async def main() -> None: sched.add_job(universe_flush_job.evict_run, CronTrigger(hour=0, minute=15), name="universe_evict_job", id="universe_evict_job") + # Editorial email digests: daily Mon-Sat for paid opt-in, weekly Sunday + # recap for everyone opt-in. Job decides which kind based on weekday. + sched.add_job(email_digest_job.run, + CronTrigger(hour=6, minute=30), + name="email_digest_job", id="email_digest_job") sched.start() log.info("scheduler.started", jobs=[j.id for j in sched.get_jobs()])