We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f0159de commit 0cd7471Copy full SHA for 0cd7471
airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py
@@ -2622,8 +2622,8 @@ def create_state_delegating_retriever(
2622
client_side_incremental_sync: Optional[Dict[str, Any]] = None,
2623
transformations: List[RecordTransformation],
2624
) -> StateDelegatingRetriever:
2625
- if not isinstance(stream_slicer, DeclarativeCursor):
2626
- raise ValueError("StateDelegatingRetriever requires a DeclarativeCursor")
+ if not isinstance(stream_slicer, DatetimeBasedCursor):
+ raise ValueError("StateDelegatingRetriever requires a DatetimeBasedCursor")
2627
2628
full_data_request_options_provider = copy.deepcopy(request_options_provider)
2629
0 commit comments