File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
airbyte_cdk/sources/declarative/parsers Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1932,13 +1932,13 @@ def create_declarative_stream(
19321932 and hasattr (model .incremental_sync , "is_data_feed" )
19331933 and model .incremental_sync .is_data_feed
19341934 )
1935- client_side_filetering_enabled = (
1935+ client_side_filtering_enabled = (
19361936 model .incremental_sync
19371937 and hasattr (model .incremental_sync , "is_client_side_incremental" )
19381938 and model .incremental_sync .is_client_side_incremental
19391939 )
19401940 concurrent_cursor = None
1941- if stop_condition_on_cursor or client_side_filetering_enabled :
1941+ if stop_condition_on_cursor or client_side_filtering_enabled :
19421942 stream_slicer = self ._build_stream_slicer_from_partition_router (
19431943 model .retriever , config , stream_name = model .name
19441944 )
@@ -2019,7 +2019,7 @@ def create_declarative_stream(
20192019 request_options_provider = request_options_provider ,
20202020 stop_condition_cursor = concurrent_cursor ,
20212021 client_side_incremental_sync = {"cursor" : concurrent_cursor }
2022- if client_side_filetering_enabled
2022+ if client_side_filtering_enabled
20232023 else None ,
20242024 transformations = transformations ,
20252025 file_uploader = file_uploader ,
You can’t perform that action at this time.
0 commit comments