code: def __process_set(data_root, dst_root):
      """
      Finds and converts all sph audio files in the given directory to wav.
      Args:
          data_folder: source directory with sph files to convert
          dst_root: where wav files will be stored
      """
      sph_list = glob.glob(data_root)
  
      if not os.path.exists(dst_root):
          os.makedirs(dst_root)
  
      # Set up and execute concurrent audio conversion
      tp = concurrent.futures.ProcessPoolExecutor(max_workers=64)
      futures = []
  
      for sph_path in tqdm(
          sph_list, desc="Submitting sph futures", unit="file"
      ):
          audio_id, _ = os.path.splitext(os.path.basename(sph_path))
          out_path = os.path.join(dst_root, "{}.wav".format(audio_id))
          futures.append(tp.submit(__convert_audio, sph_path, out_path))
  
      pbar = tqdm(
          total=len(sph_list), desc="Converting sph files", unit="file"
      )
      count = 0
      for f in concurrent.futures.as_completed(futures):
          count += 1
          pbar.update()
      tp.shutdown()
      pbar.close()
  
file_path: NeMo/scripts/dataset_processing/fisher_audio_to_wav.py
imports: import argparse
  import concurrent.futures
  import glob
  import logging
  import os
  import subprocess
  from tqdm import tqdm
label_desc: Use image node_id 2 for calling a global function with example usage: __process_set(data_root, dst_root) without return types