def METHOD_NAME():
    @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)