File tree Expand file tree Collapse file tree 1 file changed +9
-4
lines changed
Expand file tree Collapse file tree 1 file changed +9
-4
lines changed Original file line number Diff line number Diff line change @@ -369,6 +369,9 @@ def __init__(
369369 start_row_offset
370370 )
371371 )
372+
373+ self .num_links_downloaded = 0
374+
372375 if self .result_links :
373376 for result_link in self .result_links :
374377 logger .debug (
@@ -378,18 +381,20 @@ def __init__(
378381 )
379382 self .download_manager .add_link (result_link )
380383
381- # Initialize table and position
382- self .table = self ._create_next_table ()
383- else :
384- self .table = self ._create_empty_table ()
384+ # Initialize table and position
385+ self .table = self ._create_next_table ()
385386
386387 def _create_next_table (self ) -> "pyarrow.Table" :
388+ if self .num_links_downloaded >= len (self .result_links ):
389+ return self ._create_empty_table ()
390+
387391 logger .debug (
388392 "ThriftCloudFetchQueue: Trying to get downloaded file for row {}" .format (
389393 self .start_row_index
390394 )
391395 )
392396 arrow_table = self ._create_table_at_offset (self .start_row_index )
397+ self .num_links_downloaded += 1
393398 self .start_row_index += arrow_table .num_rows
394399 logger .debug (
395400 "ThriftCloudFetchQueue: Found downloaded file, row count: {}, new start offset: {}" .format (
You can’t perform that action at this time.
0 commit comments