add cleanupEvents to worker

This commit is contained in:
2023-04-16 15:24:51 -04:00
parent 723421160f
commit c4e1a7ab75

View File

@@ -1,6 +1,7 @@
from celery import Celery from celery import Celery
from celery.schedules import crontab from celery.schedules import crontab
from create_events import createEvents from create_events import createEvents
from cleanup_events import cleanupEvents
import os import os
from flask import Flask from flask import Flask
from misc import currDay, datetime, time, timedelta from misc import currDay, datetime, time, timedelta
@@ -32,11 +33,20 @@ def runCreateEvents():
with app.app_context(): with app.app_context():
createEvents(db, currDay, Period, Event) createEvents(db, currDay, Period, Event)
def runCleanupEvents():
with app.app_context():
cleanupEvents(db, Event)
# Scheduled tasks # Scheduled tasks
celerymsg.conf.beat_schedule = { celerymsg.conf.beat_schedule = {
'hourly-createevents': { 'hourly-createevents': {
'task': 'worker.runCreateEvents', 'task': 'worker.runCreateEvents',
# Run hourly # Run hourly
'schedule': crontab(hour="*", minute="59"), 'schedule': crontab(hour="*", minute="59"),
},
'monthly-cleanupevents': {
'task': 'worker.runCleanupEvents',
# Run monthly
'schedule': crontab(day_of_month="29")
} }
} }