code: def __init__(self, function, batch_size, num_threads=1, device_id=0):
      super(MultichannelPythonOpPipeline, self).__init__(
          batch_size,
          num_threads,
          device_id,
          exec_async=False,
          exec_pipelined=False,
      )
      self.reader = ops.readers.File(files=multichannel_tiff_files)
      self.decoder = ops.decoders.Image(
          device="cpu", output_type=types.ANY_DATA
      )
      self.oper = ops.PythonFunction(
          function=function, output_layouts="HWC"
      )
  
imports: from nvidia.dali.pipeline import Pipeline
  import nvidia.dali.ops
  import nvidia.dali.types
  import numpy
  import os
  from test_utils import compare_pipelines
  from test_utils import RandomDataIterator
  import cv2
  import glob
label_desc: Use image node_id 1 to create a new MultichannelPythonOpPipeline object from inherited base classes: Pipeline with example: obj = MultichannelPythonOpPipeline(function, batch_size, num_threads, device_id)