Skip to content

Commit fb75765

Browse files
author
maxime.c
committed
fix test
1 parent c94892a commit fb75765

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2244,7 +2244,7 @@ def _build_concurrent_cursor(
22442244
else:
22452245
state_transformations = []
22462246

2247-
if model.incremental_sync and stream_slicer:
2247+
if model.incremental_sync and stream_slicer and not isinstance(stream_slicer, SinglePartitionRouter):
22482248
return self.create_concurrent_cursor_from_perpartition_cursor( # type: ignore # This is a known issue that we are creating and returning a ConcurrentCursor which does not technically implement the (low-code) StreamSlicer. However, (low-code) StreamSlicer and ConcurrentCursor both implement StreamSlicer.stream_slices() which is the primary method needed for checkpointing
22492249
state_manager=self._connector_state_manager,
22502250
model_type=DatetimeBasedCursorModel,

0 commit comments

Comments
 (0)