code: def _get_swap_buffers(self, params):
      buffers = []
      for param in params:
          param_id = param.ds_id
          assert (
              param_id in self.param_id_to_swap_buffer.keys()
          ), f"param {param_id} has not been assigned a swap buffer"
          buffers.append(self.param_id_to_swap_buffer[param_id])
  
      return buffers
  
imports: import os
  import shutil
  from enum import Enum
  import torch
  from deepspeed import comm
  from deepspeed.ops.aio import AsyncIOBuilder
  from .constants import *
  from .utils import swap_in_tensors, swap_out_tensors, MIN_AIO_BYTES, AIO_ALIGNED_BYTES, print_object, SwapBufferPool
label_desc: Use image node_id 7 for calling the AsyncPartitionedParameterSwapper obj's underlying member method code with example usage: obj._get_swap_buffers(params) and returns: buffers