Skip to content

Commit

Permalink
Add comment for reading parent stream
Browse files Browse the repository at this point in the history
  • Loading branch information
tolik0 committed Jun 6, 2024
1 parent 8875233 commit 776b974
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,8 @@ 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
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 776b974

Please sign in to comment.