app/workers/celery_app.py

from celery import Celery
from celery.schedules import crontab

from app.utils.config import config_manager

config = config_manager.get_config()
celery_app = Celery("smart_chatbot", broker=config.redis_url, backend=config.redis_url)
celery_app.conf.task_serializer = "json"
celery_app.conf.result_serializer = "json"
celery_app.conf.accept_content = ["json"]
celery_app.conf.beat_schedule = {
    "expire-paused-sync-jobs-hourly": {
        "task": "app.workers.sync_job_maintenance.expire_paused_sync_jobs",
        "schedule": crontab(minute=0),  # top of every hour
    },
}
celery_app.conf.timezone = "UTC"