code: def run_and_check(pipe, ref_iterable):
      iter_ref = iter(ref_iterable)
      i = 0
      while True:
          try:
              pipe_out = pipe.run()
              data = next(iter_ref)
              data = asnumpy(data)
              check_output(pipe_out, data)
              i += 1
          except StopIteration:
              break
      assert i == len(ref_iterable)
  
imports: import functools
  import numpy
  import nvidia.dali.fn
  import nvidia.dali.ops
  from nvidia.dali import Pipeline
  from nose_utils import assert_raises
  from test_utils import check_output
label_desc: Use image node_id 6 for calling a global function with example usage: run_and_check(pipe, ref_iterable) without return types