Add DPP_CELERY_TIMEZONE conf support

frictionlessdata · Nov 23, 2020 · aba6afe · aba6afe
1 parent 9229601
commit aba6afe
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/datapackage_pipelines/celery_tasks/celery_common.py b/datapackage_pipelines/celery_tasks/celery_common.py
@@ -15,9 +15,10 @@ def get_celery_app(**kwargs):
     celery_app = Celery('dpp')
 
     broker = os.environ.get('DPP_CELERY_BROKER', 'redis://localhost:6379/6')
+    timezone = os.environ.get('DPP_CELERY_TIMEZONE', 'UTC')
 
     conf = dict(
-        CELERY_TIMEZONE='UTC',
+        CELERY_TIMEZONE=timezone,
         CELERY_REDIRECT_STDOUTS=False,
         BROKER_URL=broker,
         CELERY_RESULT_BACKEND=broker,