diff --git a/app/celery_app.py b/app/celery_app.py index 2861800..35ddf22 100644 --- a/app/celery_app.py +++ b/app/celery_app.py @@ -22,6 +22,11 @@ celery.conf.update( celery.conf.task_routes = { "tasks.admin_*": {"queue": "admin"}, "tasks.*": {"queue": "default"}, + "tasks.system_admin_*": {"queue": "system_admin"}, + "tasks.corp_admin_*": {"queue": "corp_admin"}, + "tasks.user_*": {"queue": "user_default"}, } + + celery.conf.task_default_queue = "default"