in src/azstoragetorch/io.py [0:0]
def _flush(self) -> None: self._check_for_stage_block_exceptions(wait=False) self._flush_write_buffer() self._check_for_stage_block_exceptions(wait=True)