code: def check_callback(
      parallel_pipe, pipe, epoch_size, batch_size, dtype=None
  ):
      iters_no = epoch_size // batch_size
      parallel_pipe.build()
      pipe.build()
      capture_processes(parallel_pipe._py_pool)
      compare_pipelines(parallel_pipe, pipe, batch_size, iters_no)
  
imports: import numpy
  import nvidia.dali
  from nose.tools import with_setup
  from test_pool_utils import capture_processes, teardown_function, setup_function
  from test_utils import compare_pipelines, check_batch, RandomDataIterator, RandomlyShapedDataIterator
label_desc: Use image node_id 3 for calling a global function with example usage: check_callback(parallel_pipe, pipe, epoch_size, batch_size, dtype) without return types