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()])