Merge pull request #1503 from codalab/custom_queue_patch

Fix celery_config.py
codalab · Jun 26, 2024 · 2cb826a · 2cb826a
2 parents 82fd30f + 13c7ef7
commit 2cb826a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/celery_config.py b/src/celery_config.py
@@ -33,6 +33,6 @@ def app_for_vhost(vhost):
         django_settings = copy.copy(settings)
         django_settings.CELERY_BROKER_URL = broker_url
         vhost_app.config_from_object(django_settings, namespace='CELERY')
-        vhost_app.task_queues = app.conf.task_queues
+        vhost_app.conf.task_queues = app.conf.task_queues
         _vhost_apps[vhost] = vhost_app
     return _vhost_apps[vhost]