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 <[email protected]> Authored: Wed Jun 7 16:30:05 2017 -0700 Committer: Alex Guziel <[email protected]> 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'),
