From 37e7f280d9a058ccd614587e293251f3aeabe2bf Mon Sep 17 00:00:00 2001 From: MauricioGarciaS <47052044+MauricioGarciaS@users.noreply.github.com> Date: Fri, 25 Nov 2022 12:22:56 +0100 Subject: [PATCH] Added signals queue to cron jobs by default --- ee/api/routers/crons/core_dynamic_crons.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/ee/api/routers/crons/core_dynamic_crons.py b/ee/api/routers/crons/core_dynamic_crons.py index f57b341bb..88d591269 100644 --- a/ee/api/routers/crons/core_dynamic_crons.py +++ b/ee/api/routers/crons/core_dynamic_crons.py @@ -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