openreplay/ee/api/routers/crons/ee_crons.py
2022-12-13 18:00:24 +01:00

10 lines
No EOL
236 B
Python

from chalicelib.utils import events_queue
def pg_events_queue() -> None:
events_queue.global_queue.force_flush()
ee_cron_jobs = [
{"func": pg_events_queue, "trigger": "interval", "seconds": 60*5, "misfire_grace_time": 20},
]