diff --git a/app/celery_app.py b/app/celery_app.py index 1589009..2861800 100644 --- a/app/celery_app.py +++ b/app/celery_app.py @@ -6,7 +6,7 @@ import os redis_url = os.getenv("REDIS_URL", "redis://redis:6379/0") celery = Celery( - "safira", + "app", broker=redis_url, backend=redis_url, ) @@ -18,3 +18,10 @@ celery.conf.update( timezone="UTC", enable_utc=True, ) + +celery.conf.task_routes = { + "tasks.admin_*": {"queue": "admin"}, + "tasks.*": {"queue": "default"}, +} + +celery.conf.task_default_queue = "default"