code: def _run_and_compare_outputs(
      batch_size, parallel_pipeline, serial_pipeline
  ):
      parallel_batch = parallel_pipeline.run()
      serial_batch = serial_pipeline.run()
      for parallel_output, serial_output in zip(
          parallel_batch, serial_batch
      ):
          assert len(parallel_output) == batch_size
          assert len(serial_output) == batch_size
          for i in range(batch_size):
              assert np.array_equal(
                  parallel_output[i], serial_output[i]
              )
  
imports: import copyreg
  import numpy
  import nvidia.dali.fn
  import nvidia.dali.pickling
  import os
  from nvidia.dali import pipeline_def
  from pickle import PicklingError
  from nose_utils import raises
  from test_utils import get_dali_extra_path, restrict_python_version
label_desc: Use image node_id 20 for calling a global function with example usage: _run_and_compare_outputs(batch_size, parallel_pipeline, serial_pipeline) without return types