From 828419ede1330402e79e68451ad0554a4e6342ea Mon Sep 17 00:00:00 2001 From: Casey Brown Date: Fri, 19 Feb 2016 16:45:59 -0500 Subject: [PATCH] set celery_executor to use queue name as exchange --- airflow/executors/celery_executor.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py index 5b3cd9da98818..bceefa7b0eae5 100644 --- 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'),