Skip to content

Commit da8a5a5

Browse files
fix: Convert cursor_value to str for type safety
Co-Authored-By: unknown <>
1 parent 324344f commit da8a5a5

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3612,16 +3612,18 @@ def _is_cursor_older_than_retention_period(
36123612
if not isinstance(cursor_value, (str, int)):
36133613
return False
36143614

3615+
cursor_value_str = str(cursor_value)
3616+
36153617
retention_duration = parse_duration(api_retention_period)
36163618
retention_cutoff = datetime.datetime.now(datetime.timezone.utc) - retention_duration
36173619

3618-
cursor_datetime = self._parse_cursor_datetime(cursor_value, incremental_sync, stream_name)
3620+
cursor_datetime = self._parse_cursor_datetime(cursor_value_str, incremental_sync, stream_name)
36193621
if cursor_datetime is None:
36203622
return False
36213623

36223624
if cursor_datetime < retention_cutoff:
36233625
self._emit_warning_for_stale_cursor(
3624-
stream_name, cursor_value, api_retention_period, retention_cutoff
3626+
stream_name, cursor_value_str, api_retention_period, retention_cutoff
36253627
)
36263628
return True
36273629

0 commit comments

Comments
 (0)