code: def test_if_custom_type_reducers_are_respected_by_dali_reducer():
      batch_size = 8
      parallel_pipeline = create_simple_pipeline(
          DummyCb(),
          None,
          batch_size=batch_size,
          py_num_workers=2,
          parallel=True,
      )
      parallel_pipeline.build()
      (batch,) = parallel_pipeline.run()
      assert len(batch) == batch_size
      for i in range(batch_size):
          assert np.array_equal(batch[i], np.int32([42]))
  
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 25 for calling a global function with example usage: test_if_custom_type_reducers_are_respected_by_dali_reducer() without return types