code: def __init__(
      self,
      cfg: AttrDict,
      data_source: str,
      path: str,
      split: str,
      dataset_name: str,
  ):
      super(AirstoreDataset, self).__init__(
          queue_size=cfg["DATA"][split]["BATCHSIZE_PER_REPLICA"]
      )
      self.pathmanager = create_path_manager()
      self.cfg = cfg
      self.batch_size = cfg["DATA"][split]["BATCHSIZE_PER_REPLICA"]
      self.airstore_uri = path
      self.split = split
      self.epoch = 0
      self.start_iter = 0
      self.enable_queue_dataset = cfg["DATA"][self.split][
          "ENABLE_QUEUE_DATASET"
      ]
      self.global_rank = get_rank()
      self.global_world_size = get_world_size()
      self._iterator = None
  
file_path: vissl/vissl/data/airstore_dataset.py
imports: import io
  import logging
  from typing import Any, Iterable, Tuple
  import torch
  from classy_vision.generic.distributed_util import get_rank, get_world_size
  from iopath.common.file_io import PathManager
  from PIL import Image, ImageFile
  from vissl.config import AttrDict
  from vissl.data.data_helper import get_mean_image, QueueDataset
label_desc: Use image node_id 1 to create a new AirstoreDataset object from inherited base classes: QueueDataset with example: obj = AirstoreDataset(cfg, data_source, path, split, dataset_name)