Skip to content

Commit 48c6836

Browse files
authored
fix: zero out declarative cursor on concurrent streams (#723)
1 parent 2b07f93 commit 48c6836

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2090,6 +2090,12 @@ def create_declarative_stream(
20902090
elif concurrent_cursor:
20912091
cursor = concurrent_cursor
20922092

2093+
# FIXME to be removed once we migrate everything to DefaultStream
2094+
if isinstance(retriever, SimpleRetriever):
2095+
# We zero it out here, but since this is a cursor reference, the state is still properly
2096+
# instantiated for the other components that reference it
2097+
retriever.cursor = None
2098+
20932099
partition_generator = StreamSlicerPartitionGenerator(
20942100
DeclarativePartitionFactory(
20952101
stream_name,

0 commit comments

Comments
 (0)