in src/azstoragetorch/io.py [0:0]
def _process_stage_block_futures_for_errors(self, wait: bool) -> None:
if wait:
concurrent.futures.wait(
self._in_progress_stage_block_futures,
return_when=concurrent.futures.FIRST_EXCEPTION,
)
futures_still_in_progress = []
for future in self._in_progress_stage_block_futures:
if future.done():
if (
self._stage_block_exception is None
and future.exception() is not None
):
self._stage_block_exception = future.exception()
else:
futures_still_in_progress.append(future)
self._in_progress_stage_block_futures = futures_still_in_progress
self._raise_if_fatal_write_error()