code: def test_duplicated_argument():
      @pipeline_def(
          batch_size=max_batch_size,
          num_threads=num_threads,
          device_id=device_id,
      )
      def ref_pipeline(val):
          data, _ = fn.readers.file(file_root=images_dir)
          return data + val
  
      @pipeline_def(
          batch_size=max_batch_size,
          num_threads=num_threads,
          device_id=device_id,
      )
      def pipeline_duplicated_arg(max_streams):
          data, _ = fn.readers.file(file_root=images_dir)
          return data + max_streams
  
      pipe = pipeline_duplicated_arg(max_streams=42)
      assert pipe._max_streams == -1
      ref = ref_pipeline(42)
      compare_pipelines(
          pipe, ref, batch_size=max_batch_size, N_iterations=N_ITER
      )
  
file_path: DALI/dali/test/python/test_pipeline_decorator.py
imports: from nvidia.dali import Pipeline, pipeline_def
  from nose.tools import nottest
  from nose_utils import raises
  import nvidia.dali.fn
  from test_utils import get_dali_extra_path, compare_pipelines
  import os
label_desc: Use image node_id 8 for calling a global function with example usage: test_duplicated_argument() and returns: unknown, unknown