From aba6afeeb2ab17e2df17ac597d555b1b0a2e5e71 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alexandre=20Bult=C3=A9?= Date: Mon, 23 Nov 2020 08:11:56 +0100 Subject: [PATCH] Add DPP_CELERY_TIMEZONE conf support --- datapackage_pipelines/celery_tasks/celery_common.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/datapackage_pipelines/celery_tasks/celery_common.py b/datapackage_pipelines/celery_tasks/celery_common.py index b32d6f75..4548560a 100644 --- 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,