diff --git a/amiadapters/adapters/base.py b/amiadapters/adapters/base.py index 7c4a1d7..d6a4e62 100644 --- a/amiadapters/adapters/base.py +++ b/amiadapters/adapters/base.py @@ -634,6 +634,7 @@ def _calculate_backfill_range( sink = snowflake_sink[0] end = sink.calculate_end_of_backfill_range(self.org_id, min_date, max_date) + # Normalize to naive datetimes for comparison. These values represent # calendar dates but arrive as date, naive datetime, or tz-aware datetime # depending on the Snowflake column type and query path.