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

6 lines
160 B
Python

from celery import Celery
celery_app = Celery("worker", broker="amqp://guest@queue//")
celery_app.conf.task_routes = {"app.worker.test_celery": "main-queue"}