def _check_for_stage_block_exceptions()

in src/azstoragetorch/io.py [0:0]

• 3 lines of code
• 4 McCabe index (conditional complexity)

    def _check_for_stage_block_exceptions(self, wait: bool = True) -> None:
        # Before doing any additional processing, raise if an exception has already
        # been processed especially if it is going to require us to wait for all
        # in-progress futures to complete.
        self._raise_if_fatal_write_error()
        self._process_stage_block_futures_for_errors(wait)