@@ -140,13 +140,13 @@ def _should_use_lazy_simple_retriever(
140140 name : Optional [str ] = None ,
141141 ) -> bool :
142142 if (
143- model .partition_router
144- and isinstance (model .partition_router , SubstreamPartitionRouterModel )
145- and not bool (additional_flags .connector_state_manager .get_stream_state (name , None ))
146- and any (
147- parent_stream_config .lazy_read_pointer
148- for parent_stream_config in model .partition_router .parent_stream_configs
149- )
143+ model .partition_router
144+ and isinstance (model .partition_router , SubstreamPartitionRouterModel )
145+ and not bool (additional_flags .connector_state_manager .get_stream_state (name , None ))
146+ and any (
147+ parent_stream_config .lazy_read_pointer
148+ for parent_stream_config in model .partition_router .parent_stream_configs
149+ )
150150 ):
151151 if incremental_sync :
152152 if incremental_sync .type != "DatetimeBasedCursor" :
@@ -324,7 +324,7 @@ def _get_log_formatter(
324324 if not request_options_provider :
325325 request_options_provider = DefaultRequestOptionsProvider (parameters = {})
326326 if isinstance (request_options_provider , DefaultRequestOptionsProvider ) and isinstance (
327- partition_router , PartitionRouter
327+ partition_router , PartitionRouter
328328 ):
329329 request_options_provider = partition_router
330330
@@ -342,7 +342,7 @@ def _get_log_formatter(
342342 )
343343
344344 ignore_stream_slicer_parameters_on_paginated_requests = (
345- model .ignore_stream_slicer_parameters_on_paginated_requests or False
345+ model .ignore_stream_slicer_parameters_on_paginated_requests or False
346346 )
347347
348348 resolved_dependencies = {
0 commit comments