diff --git a/superset/utils.py b/superset/utils.py index b1583084eb..483058e78f 100644 --- a/superset/utils.py +++ b/superset/utils.py @@ -710,7 +710,8 @@ def get_celery_app(config): global _celery_app if _celery_app: return _celery_app - _celery_app = celery.Celery(config_source=config.get('CELERY_CONFIG')) + _celery_app = celery.Celery() + _celery_app.config_from_object(config.get('CELERY_CONFIG')) return _celery_app