@@ -201,20 +201,20 @@ def _group_streams(
201201 .get ("retriever" , {})
202202 .get ("partition_router" )
203203 )
204- is_datetime_incremental_with_partition_routing = (
205- self ._is_datetime_incremental_with_partition_routing (
204+ is_datetime_incremental_without_partition_routing = (
205+ self ._is_datetime_incremental_without_partition_routing (
206206 datetime_based_cursor_component_definition , declarative_stream
207207 )
208208 )
209209 if (
210210 is_without_partition_router_nor_cursor
211- or is_datetime_incremental_with_partition_routing
211+ or is_datetime_incremental_without_partition_routing
212212 ):
213213 stream_state = state_manager .get_stream_state (
214214 stream_name = declarative_stream .name , namespace = declarative_stream .namespace
215215 )
216216
217- if is_datetime_incremental_with_partition_routing :
217+ if is_datetime_incremental_without_partition_routing :
218218 cursor : Cursor = (
219219 self ._constructor .create_concurrent_cursor_from_datetime_based_cursor (
220220 state_manager = state_manager ,
@@ -268,7 +268,7 @@ def _group_streams(
268268
269269 return concurrent_streams , synchronous_streams
270270
271- def _is_datetime_incremental_with_partition_routing (
271+ def _is_datetime_incremental_without_partition_routing (
272272 self ,
273273 datetime_based_cursor_component_definition : Mapping [str , Any ],
274274 declarative_stream : DeclarativeStream ,
0 commit comments