code: def _update_inflight_swap_in(
      self, params, swap_in_buffers, inflight_numel
  ):
      self.inflight_params.extend(params)
      self.inflight_swap_in_buffers.extend(swap_in_buffers)
      self.inflight_numel += inflight_numel
  
      for param in params:
          param.ds_tensor.status = PartitionedParamStatus.INFLIGHT
  
      self.pending_reads += len(params)
  
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 15 for calling the AsyncPartitionedParameterSwapper obj's underlying member method code with example usage: obj._update_inflight_swap_in(params, swap_in_buffers, inflight_numel) without return types