code: def __test_numpy_closure(shape, py_callback_pickler):
      batch_size = 8
      epochs_num = 3
      callback = create_closure_callback_numpy(
          shape, data_set_size=epochs_num * batch_size
      )
      parallel_pipeline = create_simple_pipeline(
          callback,
          py_callback_pickler,
          batch_size=batch_size,
          py_num_workers=2,
          parallel=True,
      )
      serial_pipeline = create_simple_pipeline(
          callback, None, batch_size=batch_size, parallel=False
      )
      _build_and_compare_pipelines_epochs(
          epochs_num, batch_size, parallel_pipeline, serial_pipeline
      )
  
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 42 for calling a global function with example usage: __test_numpy_closure(shape, py_callback_pickler) without return types