File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
airbyte_cdk/sources/declarative Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -220,7 +220,8 @@ def _group_streams(
220220 if (
221221 name_to_stream_mapping [declarative_stream .name ]
222222 .get ("retriever" , {})
223- .get ("full_refresh_no_slice_in_params" , False ) and incremental_sync_component_definition
223+ .get ("full_refresh_no_slice_in_params" , False )
224+ and incremental_sync_component_definition
224225 ):
225226 incremental_sync_component_definition ["step" ] = None
226227 incremental_sync_component_definition ["cursor_granularity" ] = None
Original file line number Diff line number Diff line change @@ -1808,10 +1808,11 @@ def _build_incremental_cursor(
18081808 stream_slicer : Optional [PartitionRouter ],
18091809 config : Config ,
18101810 ) -> Optional [StreamSlicer ]:
1811-
18121811 if model .retriever .type == "StateDelegatingRetriever" :
18131812 if not model .incremental_sync :
1814- raise ValueError ("StateDelegatingRetriever requires 'incremental_sync' to be enabled." )
1813+ raise ValueError (
1814+ "StateDelegatingRetriever requires 'incremental_sync' to be enabled."
1815+ )
18151816 elif model .incremental_sync .type != "DatetimeBasedCursor" :
18161817 raise ValueError ("StateDelegatingRetriever support only DatetimeBasedCursor." )
18171818 elif model .retriever .full_refresh_no_slice_in_params :
You can’t perform that action at this time.
0 commit comments