code: def _create_dataloader(self):
      if self.collate_fn is None:
          self.dataloader = DataLoader(
              self.dataset,
              batch_size=self.batch_size,
              pin_memory=self.pin_memory,
              sampler=self.data_sampler,
              num_workers=self.num_local_io_workers,
              drop_last=self.dataloader_drop_last,
          )
      else:
          self.dataloader = DataLoader(
              self.dataset,
              batch_size=self.batch_size,
              pin_memory=self.pin_memory,
              sampler=self.data_sampler,
              collate_fn=self.collate_fn,
              num_workers=self.num_local_io_workers,
              drop_last=self.dataloader_drop_last,
          )
      self.data = (x for x in self.dataloader)
  
      return self.dataloader
  
file_path: H2O/h2o_flexgen/benchmark/third_party/DeepSpeed/deepspeed/runtime/dataloader.py
imports: import torch
  from torch.utils.data import DataLoader, RandomSampler
  from torch.utils.data.distributed import DistributedSampler
label_desc: Use image node_id 5 for calling the DeepSpeedDataLoader obj's underlying member method code with example usage: obj._create_dataloader() and returns: self