Merge pull request #2435 from WikiWatershed/cpc/fix-celery-stack-queue

Ensure Celery tasks get routed to matching worker
WikiWatershed · Oct 31, 2017 · dd7b61a · dd7b61a
2 parents 4b24200 + e76168e
commit dd7b61a
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/mmw/mmw/settings/base.py b/src/mmw/mmw/settings/base.py
@@ -130,8 +130,14 @@ def get_env_setting(setting):
 STATSD_CELERY_SIGNALS = True
 CELERY_CREATE_MISSING_QUEUES = True
 CELERY_CHORD_PROPAGATES = True
-CELERY_DEFAULT_QUEUE = STACK_COLOR
-CELERY_DEFAULT_ROUTING_KEY = "task.%s" % STACK_COLOR
+CELERY_TASK_DEFAULT_QUEUE = STACK_COLOR
+CELERY_TASK_QUEUES = {
+    STACK_COLOR: {
+        'binding_key': "task.%s" % STACK_COLOR,
+    }
+}
+CELERY_TASK_DEFAULT_EXCHANGE = 'tasks'
+CELERY_TASK_DEFAULT_ROUTING_KEY = "task.%s" % STACK_COLOR
 # END CELERY CONFIGURATION