code: def __call__(self, *inputs, **kwargs):
      inputs = ops._preprocess_inputs(
          inputs, self._impl_name, self._device, None
      )
      self.pipeline = _Pipeline.current()
      if self.pipeline is None:
          _Pipeline._raise_pipeline_required("PythonFunction operator")
  
      for inp in inputs:
          if not isinstance(inp, _DataNode):
              raise TypeError(
                  f"Expected inputs of type `DataNode`. "
                  f"Received input of type '{type(inp).__name__}'. "
                  f"Python Operators do not support Multiple Input Sets."
              )
  
      args, arg_inputs = ops._separate_kwargs(kwargs)
      args.update(
          {
              "function_id": id(self.function),
              "num_outputs": self.num_outputs,
          }
      )
  
      args = ops._resolve_double_definitions(
          args, self._init_args, keep_old=False
      )
      if self._name is not None:
          args = ops._resolve_double_definitions(
              args, {"name": self._name}
          )  # restore the name
  
      op_instance = ops._OperatorInstance(
          inputs, arg_inputs, args, self._init_args, self
      )
      op_instance.spec.AddArg("device", self.device)
      return op_instance.unwrapped_outputs
  
imports: import nvidia.dali.python_function_plugin
  from nvidia.dali import backend
  from nvidia.dali import ops
  from nvidia.dali.ops import _registry
  from nvidia.dali.data_node import DataNode
  from nvidia.dali.pipeline import Pipeline
  from nvidia.dali.types import CUDAStream
label_desc: Use image node_id 6 for calling the PythonFunctionBase obj's underlying member method code with example usage: obj.__call__() and returns: op_instance