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,