code: def __init__(
      self,
      batch_size=BATCH_SIZE,
      num_threads=NUM_WORKERS,
      device_id=DEVICE_ID,
      image_dir=images_dir,
  ):
      super().__init__(
          batch_size,
          num_threads,
          device_id,
          exec_async=False,
          exec_pipelined=False,
      )
      self.input = ops.readers.File(file_root=image_dir)
      self.decode = ops.decoders.Image(
          device="cpu", output_type=types.RGB
      )
  
imports: import numpy
  import nvidia.dali.ops
  import nvidia.dali.plugin.pytorch
  import nvidia.dali.types
  import os
  import torch
  from nvidia.dali.pipeline import Pipeline
  from test_utils import get_dali_extra_path
label_desc: Use image node_id 1 to create a new CommonPipeline object from inherited base classes: Pipeline with example: obj = CommonPipeline(batch_size, num_threads, device_id, image_dir)