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 @@ -373,18 +373,19 @@ def _progress_chunk_link(self):
373
373
374
374
if next_chunk_index is None :
375
375
self ._current_chunk_link = None
376
- else :
377
- try :
378
- self . _current_chunk_link = self . _sea_client . get_chunk_link (
379
- self ._statement_id , next_chunk_index
380
- )
381
- except Exception as e :
382
- logger . error (
383
- "SeaCloudFetchQueue: Error fetching link for chunk {}: {}" . format (
384
- next_chunk_index , e
385
- )
376
+ return None
377
+
378
+ try :
379
+ self . _current_chunk_link = self ._sea_client . get_chunk_link (
380
+ self . _statement_id , next_chunk_index
381
+ )
382
+ except Exception as e :
383
+ logger . error (
384
+ "SeaCloudFetchQueue: Error fetching link for chunk {}: {}" . format (
385
+ next_chunk_index , e
386
386
)
387
- return None
387
+ )
388
+ return None
388
389
389
390
logger .debug (
390
391
f"SeaCloudFetchQueue: Progressed to link for chunk { next_chunk_index } : { self ._current_chunk_link } "
You can’t perform that action at this time.
0 commit comments