File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
airbyte_cdk/sources/declarative/retrievers Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -367,25 +367,24 @@ def _read_pages(
367367 {"next_page_token" : initial_token } if initial_token is not None else None
368368 )
369369 while not pagination_complete :
370- property_chunks = (
370+ property_chunks : List [ List [ str ]] = (
371371 list (
372372 self .additional_query_properties .get_request_property_chunks (
373373 stream_slice = stream_slice
374374 )
375375 )
376376 if self .additional_query_properties
377377 else [
378- None
379- ] # A single None property chunk represents the case where property chunking is not configured
378+ []
379+ ] # A single empty property chunk represents the case where property chunking is not configured
380380 )
381381
382- records_without_merge_key = []
383382 merged_records : MutableMapping [str , Any ] = defaultdict (dict )
384383 last_page_size = 0
385384 last_record : Optional [Record ] = None
386385 response : Optional [requests .Response ] = None
387386 for properties in property_chunks :
388- if properties :
387+ if len ( properties ) > 0 :
389388 stream_slice = StreamSlice (
390389 partition = stream_slice .partition or {},
391390 cursor_slice = stream_slice .cursor_slice or {},
You can’t perform that action at this time.
0 commit comments