code: def _flush_buffers_until_complete(self):
      self._flush_ready_buffers()
      assert len(self.ready_buffer_index) == 0
  
      self._wait_for_swap_complete()
      assert len(self.swapping_buffer_index) == 0
      assert len(self.free_buffer_index) == len(self.all_buffers)
  
imports: import torch
  from deepspeed import comm
  from deepspeed.utils.logging import logger
  from deepspeed.runtime.swap_tensor.utils import swap_out_tensors, SwapBuffer
  from deepspeed.accelerator import get_accelerator
label_desc: Use image node_id 13 for calling the AsyncTensorSwapper obj's underlying member method code with example usage: obj._flush_buffers_until_complete() without return types