set celery_executor to use queue name as exchange

caseybrown89 · Feb 19, 2016 · 828419e · 828419e
1 parent 8be0296
commit 828419e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
@@ -28,6 +28,7 @@ class CeleryConfig(object):
     CELERY_RESULT_BACKEND = configuration.get('celery', 'CELERY_RESULT_BACKEND')
     CELERYD_CONCURRENCY = configuration.getint('celery', 'CELERYD_CONCURRENCY')
     CELERY_DEFAULT_QUEUE = DEFAULT_QUEUE
+    CELERY_DEFAULT_EXCHANGE = DEFAULT_QUEUE
 
 app = Celery(
     configuration.get('celery', 'CELERY_APP_NAME'),