code: def _chunk_process_wrapper(fn, chunk):
      return list(map(fn, chunk))
  
file_path: speechbrain/speechbrain/utils/parallel.py
imports: import itertools
  import multiprocessing
  from collections import deque
  from concurrent.futures import Executor, ProcessPoolExecutor
  from threading import Condition
  from typing import Any, Callable, Iterable, Optional
  from tqdm.auto import tqdm
label_desc: Use image node_id 1 for calling a global function with example usage: _chunk_process_wrapper(fn, chunk) and returns: list