diff --git a/posthog/temporal/batch_exports/snowflake_batch_export.py b/posthog/temporal/batch_exports/snowflake_batch_export.py index 137b32df56dec..4d966fc4e00a4 100644 --- a/posthog/temporal/batch_exports/snowflake_batch_export.py +++ b/posthog/temporal/batch_exports/snowflake_batch_export.py @@ -466,7 +466,7 @@ async def flush_to_snowflake( interval_end=inputs.data_interval_end, exclude_events=inputs.exclude_events, include_events=inputs.include_events, - destination_destination_default_fields=snowflake_default_fields(), + destination_default_fields=snowflake_default_fields(), is_backfill=inputs.is_backfill, ) first_record_batch, record_iterator = await apeek_first_and_rewind(record_iterator)