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), "misfire_grace_time": 20,
     "max_instances": 1}
]