File tree Expand file tree Collapse file tree 1 file changed +3
-16
lines changed
airbyte_cdk/sources/declarative Expand file tree Collapse file tree 1 file changed +3
-16
lines changed Original file line number Diff line number Diff line change @@ -468,24 +468,11 @@ def _is_concurrent_cursor_incremental_without_partition_routing(
468
468
def _get_retriever (
469
469
declarative_stream : DeclarativeStream , stream_state : Mapping [str , Any ]
470
470
) -> Retriever :
471
- retriever = declarative_stream .retriever
472
-
473
- # This is an optimization so that we don't invoke any cursor or state management flows within the
474
- # low-code framework because state management is handled through the ConcurrentCursor.
475
- if declarative_stream and isinstance (retriever , SimpleRetriever ):
476
- # Also a temporary hack. In the legacy Stream implementation, as part of the read,
477
- # set_initial_state() is called to instantiate incoming state on the cursor. Although we no
478
- # longer rely on the legacy low-code cursor for concurrent checkpointing, low-code components
479
- # like StopConditionPaginationStrategyDecorator still rely on a DatetimeBasedCursor that is
480
- # properly initialized with state.
481
- if retriever .cursor :
482
- retriever .cursor .set_initial_state (stream_state = stream_state )
483
-
471
+ if declarative_stream and isinstance (declarative_stream .retriever , SimpleRetriever ):
484
472
# We zero it out here, but since this is a cursor reference, the state is still properly
485
473
# instantiated for the other components that reference it
486
- retriever .cursor = None
487
-
488
- return retriever
474
+ declarative_stream .retriever .cursor = None
475
+ return declarative_stream .retriever
489
476
490
477
@staticmethod
491
478
def _select_streams (
You can’t perform that action at this time.
0 commit comments