code: def __call__(self, *inputs, **kwargs):
      pipeline = Pipeline.current()
      if pipeline is None:
          Pipeline._raise_no_current_pipeline("TorchPythonFunction")
      if self.stream is None:
          self.stream = torch.cuda.Stream(device=pipeline.device_id)
      return super(TorchPythonFunction, self).__call__(
          *inputs, **kwargs
      )
  
file_path: DALI/dali/python/nvidia/dali/plugin/pytorch/_torch_function.py
imports: import torch
  import torch.utils.dlpack
  from nvidia.dali import ops
  from nvidia.dali.pipeline import Pipeline
label_desc: Use image node_id 3 for calling the TorchPythonFunction obj's underlying member method code with example usage: obj.__call__() and returns: super