diff --git a/posthog/temporal/data_imports/workflow_activities/import_data.py b/posthog/temporal/data_imports/workflow_activities/import_data.py index b6806071e721e..5da7e1fc1b109 100644 --- a/posthog/temporal/data_imports/workflow_activities/import_data.py +++ b/posthog/temporal/data_imports/workflow_activities/import_data.py @@ -67,9 +67,8 @@ async def import_data_activity(inputs: ImportDataActivityInputs) -> tuple[TSchem # Hacky just for specific user region = get_instance_region() if region == "EU" and inputs.team_id == 11870: - prev_day = timezone.now() - dt.timedelta(days=1) - start_date = prev_day.replace(hour=0, minute=0, second=0, microsecond=0) - end_date = start_date + dt.timedelta(1) + start_date = timezone.now().replace(day=1, hour=0, minute=0, second=0, microsecond=0) + end_date = start_date + dt.timedelta(weeks=5) else: start_date = None end_date = None