Skip to content

Commit 293d4f1

Browse files
committed
clarifying comment
1 parent d7aa54d commit 293d4f1

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

airbyte_cdk/sources/declarative/concurrent_declarative_source.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,6 +242,8 @@ def _group_streams(
242242
# still rely on a DatetimeBasedCursor that is properly initialized with state.
243243
if retriever.cursor:
244244
retriever.cursor.set_initial_state(stream_state=stream_state)
245+
# We zero it out here, but since this is a cursor reference, the state is still properly
246+
# instantiated for the other components that reference it
245247
retriever.cursor = None
246248

247249
partition_generator = StreamSlicerPartitionGenerator(

0 commit comments

Comments
 (0)