airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From saguz...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1265] Fix exception while loading celery configurations
Date Wed, 07 Jun 2017 23:30:14 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master b13cd6db9 -> 38cbf132a


[AIRFLOW-1265] Fix exception while loading celery configurations

Closes #2340 from orezahc/celery-bug-fix


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/38cbf132
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/38cbf132
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/38cbf132

Branch: refs/heads/master
Commit: 38cbf132ad7b1bc86c9b73c058f90abc01119681
Parents: b13cd6d
Author: chao <chazerod@gmail.com>
Authored: Wed Jun 7 16:30:05 2017 -0700
Committer: Alex Guziel <alex.guziel@airbnb.com>
Committed: Wed Jun 7 16:30:05 2017 -0700

----------------------------------------------------------------------
 airflow/executors/celery_executor.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/38cbf132/airflow/executors/celery_executor.py
----------------------------------------------------------------------
diff --git a/airflow/executors/celery_executor.py b/airflow/executors/celery_executor.py
index 4de8252..0b6cd59 100644
--- a/airflow/executors/celery_executor.py
+++ b/airflow/executors/celery_executor.py
@@ -47,7 +47,7 @@ class CeleryConfig(object):
     CELERYD_CONCURRENCY = configuration.getint('celery', 'CELERYD_CONCURRENCY')
     CELERY_DEFAULT_QUEUE = DEFAULT_QUEUE
     CELERY_DEFAULT_EXCHANGE = DEFAULT_QUEUE
-    if configuration.get('celery', 'CELERY_SSL_ACTIVE'):
+    if configuration.getboolean('celery', 'CELERY_SSL_ACTIVE'):
         try:
             BROKER_USE_SSL = {'keyfile': configuration.get('celery', 'CELERY_SSL_KEY'),
                               'certfile': configuration.get('celery', 'CELERY_SSL_CERT'),


Mime
View raw message