From 307a3d7195b01f4208db825517550f120eda8008 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A9r=C3=B4me=20Lafr=C3=A9choux?= Date: Fri, 6 Jun 2025 14:31:34 +0200 Subject: [PATCH] AsyncTask: ensure start_dt and end_dt in campaign timezone --- src/bemserver_core/celery.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/bemserver_core/celery.py b/src/bemserver_core/celery.py index bfb6528..cdb3d4b 100644 --- a/src/bemserver_core/celery.py +++ b/src/bemserver_core/celery.py @@ -66,7 +66,7 @@ class BEMServerCoreAsyncTask(BEMServerCoreClassBasedTaskMixin, Task): TASK_FUNCTION = None DEFAULT_PARAMETERS = {} - def run(self, user_id, campaign_id, start_td, end_dt, **kwargs): + def run(self, user_id, campaign_id, start_dt, end_dt, **kwargs): logger.info("Start") with OpenBar(): @@ -82,8 +82,8 @@ def run(self, user_id, campaign_id, start_td, end_dt, **kwargs): # Function is bound at init. Use __func__ to avoid passing self self.TASK_FUNCTION.__func__( campaign, - start_td, - end_dt, + start_dt.astimezone(campaign.timezone), + end_dt.astimezone(campaign.timezone), **{**self.DEFAULT_PARAMETERS, **kwargs}, )