diff --git a/superset/utils.py b/superset/utils.py index 387b8522dcab6..56a893607aa46 100644 --- a/superset/utils.py +++ b/superset/utils.py @@ -705,7 +705,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