Skip to content

Commit 8a70640

Browse files
committed
CDK: ref
Signed-off-by: Artem Inzhyyants <[email protected]>
1 parent 1f668b8 commit 8a70640

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -416,9 +416,6 @@ def _is_datetime_incremental_without_partition_routing(
416416
incremental_sync_component_definition.get("type", "")
417417
in (DatetimeBasedCursorModel.__name__, IncrementingCountCursorModel.__name__)
418418
)
419-
and self._stream_supports_concurrent_partition_processing(
420-
declarative_stream=declarative_stream
421-
)
422419
and hasattr(declarative_stream.retriever, "stream_slicer")
423420
and (
424421
isinstance(declarative_stream.retriever.stream_slicer, DatetimeBasedCursor)

0 commit comments

Comments
 (0)