in src/azstoragetorch/io.py [0:0]
def _commit_blob(self) -> None:
self._flush()
block_ids = [f.result() for f in self._all_stage_block_futures]
self._raise_if_duplicate_block_ids(block_ids)
self._client.commit_block_list(block_ids)