Files
Aether/backend/app/core/celery_app.py
T

11 lines
215 B
Python

from celery import Celery
from app.core.config import settings
celery_app = Celery(
"app.core.celery_app",
broker=settings.RABBITMQ_URL,
backend="rpc://"
)
celery_app.autodiscover_tasks(["app.tasks"])