code: def __init__(
      self,
      device,
      batch_size,
      layout,
      iterator,
      anchor,
      shape,
      axis_names,
      axes,
      fill_value,
      normalized_anchor=False,
      normalized_shape=False,
      num_threads=1,
      device_id=0,
      num_gpus=1,
  ):
      super(ErasePipeline, self).__init__(
          batch_size, num_threads, device_id
      )
      self.device = device
      self.layout = layout
      self.iterator = iterator
      self.inputs = ops.ExternalSource()
  
      if isinstance(fill_value, RandomDataIterator):
          self.fill_value_iterator = fill_value
          self.fill_value_inputs = ops.ExternalSource()
          fill_value = None
      else:
          self.fill_value_iterator = None
  
      self.erase = ops.Erase(
          device=self.device,
          anchor=anchor,
          shape=shape,
          axis_names=axis_names,
          axes=axes,
          fill_value=fill_value,
          normalized_anchor=normalized_anchor,
          normalized_shape=normalized_shape,
      )
  
imports: from nvidia.dali.pipeline import Pipeline
  import nvidia.dali.ops
  import numpy
  from functools import partial
  from test_utils import compare_pipelines
  from test_utils import RandomDataIterator
label_desc: Use image node_id 1 to create a new ErasePipeline object from inherited base classes: Pipeline with example: obj = ErasePipeline(device, batch_size, layout, iterator, anchor, shape, axis_names, axes, fill_value, normalized_anchor, normalized_shape, num_threads, device_id, num_gpus)