code: def _torch_stream_wrapper(self, function, *ins):
      with torch.cuda.stream(self.stream):
          out = function(*ins)
      self.stream.synchronize()
      return out
  
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 1 for calling the TorchPythonFunction obj's underlying member method code with example usage: obj._torch_stream_wrapper(function) and returns: out