File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
airbyte_cdk/sources/streams/http Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -423,7 +423,6 @@ def _read_pages(
423423 stream_slice : Optional [Mapping [str , Any ]] = None ,
424424 stream_state : Optional [Mapping [str , Any ]] = None ,
425425 ) -> Iterable [StreamData ]:
426- partition , _ , _ = self ._extract_slice_fields (stream_slice = stream_slice )
427426
428427 stream_state = stream_state or {}
429428 pagination_complete = False
@@ -438,6 +437,7 @@ def _read_pages(
438437
439438 cursor = self .get_cursor ()
440439 if cursor and isinstance (cursor , SubstreamResumableFullRefreshCursor ):
440+ partition , _ , _ = self ._extract_slice_fields (stream_slice = stream_slice )
441441 # Substreams checkpoint state by marking an entire parent partition as completed so that on the subsequent attempt
442442 # after a failure, completed parents are skipped and the sync can make progress
443443 cursor .close_slice (StreamSlice (cursor_slice = {}, partition = partition ))
You can’t perform that action at this time.
0 commit comments