File size: 795 Bytes
25f22bf 1d6d1e6 25f22bf 1d6d1e6 25f22bf |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 |
from celery import Celery
from celery.schedules import crontab
import os
# Import the task function
from backend.celery_tasks.schedule_loader import load_schedules_task
# Create Celery instance for Beat scheduler
celery_beat = Celery('lin_scheduler')
# Configure Celery Beat
celery_beat.conf.broker_url = os.environ.get('CELERY_BROKER_URL', 'redis://localhost:6379/0')
celery_beat.conf.result_backend = os.environ.get('CELERY_RESULT_BACKEND', 'redis://localhost:6379/0')
# Configure schedules
celery_beat.conf.beat_schedule = {
# This task will run every 5 minutes to load schedules from the database
'load-schedules': {
'task': 'backend.celery_tasks.schedule_loader.load_schedules_task',
'schedule': crontab(minute='*/5'),
},
}
celery_beat.conf.timezone = 'UTC' |