openreplay/ee/api/routers/crons/ee_crons.py
Taha Yassine Kraiem c6ebeeba7c feat(chalice): upgraded dependencies
feat(crons): changed triggers
2022-12-30 11:36:20 +01:00

12 lines
321 B
Python

from apscheduler.triggers.interval import IntervalTrigger
from chalicelib.utils import events_queue
async def pg_events_queue() -> None:
events_queue.global_queue.force_flush()
ee_cron_jobs = [
{"func": pg_events_queue, "trigger": IntervalTrigger(minutes=5), "misfire_grace_time": 20, "max_instances": 1},
]