File tree Expand file tree Collapse file tree 1 file changed +12
-11
lines changed Expand file tree Collapse file tree 1 file changed +12
-11
lines changed Original file line number Diff line number Diff line change @@ -306,7 +306,6 @@ def __init__(
306
306
description: Column descriptions
307
307
"""
308
308
super ().__init__ (
309
- schema_bytes = b"" ,
310
309
max_download_threads = max_download_threads ,
311
310
ssl_options = ssl_options ,
312
311
lz4_compressed = lz4_compressed ,
@@ -357,17 +356,19 @@ def _progress_chunk_link(self):
357
356
358
357
next_chunk_index = self ._current_chunk_link .next_chunk_index
359
358
360
- self ._current_chunk_link = None
361
- try :
362
- self ._current_chunk_link = self ._sea_client .get_chunk_link (
363
- self ._statement_id , next_chunk_index
364
- )
365
- except Exception as e :
366
- logger .error (
367
- "SeaCloudFetchQueue: Error fetching link for chunk {}: {}" .format (
368
- next_chunk_index , e
359
+ if next_chunk_index is None :
360
+ self ._current_chunk_link = None
361
+ else :
362
+ try :
363
+ self ._current_chunk_link = self ._sea_client .get_chunk_link (
364
+ self ._statement_id , next_chunk_index
365
+ )
366
+ except Exception as e :
367
+ logger .error (
368
+ "SeaCloudFetchQueue: Error fetching link for chunk {}: {}" .format (
369
+ next_chunk_index , e
370
+ )
369
371
)
370
- )
371
372
logger .debug (
372
373
f"SeaCloudFetchQueue: Progressed to link for chunk { next_chunk_index } : { self ._current_chunk_link } "
373
374
)
You can’t perform that action at this time.
0 commit comments