giorgio/read.markets
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

scheduler: register email_digest_job at 06:30 UTC

Browse source
This commit is contained in:
Giorgio Gilestro 2026-05-25 23:20:06 +02:00
parent 82e529b6b2
commit 5c89f4d04a
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
app/scheduler_main.py
View file

@ -13,7 +13,7 @@ from app.db import get_engine
from app.logging import configure_logging, get_logger from app.logging import configure_logging, get_logger
from app.jobs import ( from app.jobs import (
market_job, news_job, ai_log_job, rollup_job, 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, sched.add_job(universe_flush_job.evict_run,
CronTrigger(hour=0, minute=15), CronTrigger(hour=0, minute=15),
name="universe_evict_job", id="universe_evict_job") 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() sched.start()
log.info("scheduler.started", jobs=[j.id for j in sched.get_jobs()]) log.info("scheduler.started", jobs=[j.id for j in sched.get_jobs()])