def METHOD_NAME(
    wav_scp, processing_num=1, data_root="MISP_121h", output_root="MISP_121h_WPE_"
):
    if processing_num > 1:
        pool = Pool(processes=processing_num)
        for i in range(processing_num):
            pool.apply_async(
                wpe_worker,
                kwds={
                    "wav_scp": wav_scp,
                    "processing_id": i,
                    "processing_num": processing_num,
                    "data_root": data_root,
                    "output_root": output_root,
                },
            )
        pool.close()
        pool.join()
    else:
        wpe_worker(wav_scp, data_root=data_root, output_root=output_root)
    return None