Merge pull request #1041 from caseybrown89/master

set celery_executor to use queue name as exchange
apache · Apr 1, 2016 · 0d9c0ac · 0d9c0ac
2 parents 78f5640 + 828419e
commit 0d9c0ac
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'),