19 lines
587 B
Python
19 lines
587 B
Python
from apscheduler.triggers.interval import IntervalTrigger
|
|
|
|
from chalicelib.utils import events_queue
|
|
from chalicelib.core import assist_stats
|
|
|
|
|
|
async def pg_events_queue() -> None:
|
|
events_queue.global_queue.force_flush()
|
|
|
|
|
|
async def assist_events_aggregates_cron() -> None:
|
|
assist_stats.insert_aggregated_data()
|
|
|
|
|
|
ee_cron_jobs = [
|
|
{"func": pg_events_queue, "trigger": IntervalTrigger(minutes=5), "misfire_grace_time": 20, "max_instances": 1},
|
|
{"func": assist_events_aggregates_cron,
|
|
"trigger": IntervalTrigger(hours=1, start_date="2023-04-01 0:0:0", jitter=10), }
|
|
]
|