Skip to content

Commit e6db281

Browse files
fix: convert AirbyteDateTime to standard datetime before subtraction
Co-Authored-By: Aaron <AJ> Steers <[email protected]>
1 parent c4f2e3a commit e6db281

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

airbyte_cdk/sources/declarative/incremental/datetime_based_cursor.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,11 @@ def _partition_daterange(
267267

268268
while self._is_within_date_range(start, end):
269269
next_start = self._evaluate_next_start_date_safely(start, step)
270-
end_date = self._get_date(next_start - self._cursor_granularity, end, min)
270+
if hasattr(next_start, "to_datetime"):
271+
next_start_dt = next_start.to_datetime()
272+
else:
273+
next_start_dt = next_start
274+
end_date = self._get_date(next_start_dt - self._cursor_granularity, end, min)
271275
dates.append(
272276
StreamSlice(
273277
partition={},

0 commit comments

Comments
 (0)