Skip to content

Commit

Permalink
Update comment
Browse files Browse the repository at this point in the history
  • Loading branch information
tolik0 committed Jun 6, 2024
1 parent 776b974 commit ad0d49b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ def stream_slices(self) -> Iterable[StreamSlice]:
# we need to read all records for slice to update the parent stream cursor
stream_slices_for_parent = []

# only stream_slice param is used in the declarative stream
# only stream_slice param is used in the declarative stream, stream state is set in PerPartitionCursor set_initial_state
for parent_record in parent_stream.read_records(
sync_mode=SyncMode.full_refresh, cursor_field=None, stream_slice=parent_stream_slice, stream_state=None
):
Expand Down

0 comments on commit ad0d49b

Please sign in to comment.