jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added signals queue to cron jobs by default

Browse source
This commit is contained in:
MauricioGarciaS 2022-11-25 12:22:56 +01:00
parent 2e9ff89976
commit 37e7f280d9
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
ee/api/routers/crons/core_dynamic_crons.py
View file

@ -27,14 +27,15 @@ def pg_events_queue() -> None:
events_queue.global_queue.force_flush()
cron_jobs = [
{"func": unlock_cron, "trigger": "cron", "hour": "*"}
{"func": unlock_cron, "trigger": "cron", "hour": "*"},
{"func": pg_events_queue, "trigger": "interval", "seconds": 60*5, "misfire_grace_time": 20}
]
SINGLE_CRONS = [{"func": telemetry_cron, "trigger": "cron", "day_of_week": "*"},
{"func": run_scheduled_jobs, "trigger": "interval", "seconds": 60, "misfire_grace_time": 20},
{"func": weekly_report, "trigger": "cron", "day_of_week": "mon", "hour": 5,
"misfire_grace_time": 60 * 60},
{"func": pg_events_queue, "trigger": "cron", "interval": 60*5, "misfire_grace_time": 20}]
"misfire_grace_time": 60 * 60}
]
if config("LOCAL_CRONS", default=False, cast=bool):
cron_jobs += SINGLE_CRONS