def merge_inputs(*, fuzz_pool, corpus, test_list, build_dir, merge_dir):
    logging.info('Merge the inputs in the passed dir into the seed_dir. Passed dir {}'.format(merge_dir))
    jobs = []
    for t in test_list:
        args = [os.path.join(build_dir, 'src', 'test', 'fuzz', t), '-merge=1', '-use_value_profile=1', os.path.join(corpus, t), os.path.join(merge_dir, t)]
        os.makedirs(os.path.join(corpus, t), exist_ok=True)
        os.makedirs(os.path.join(merge_dir, t), exist_ok=True)

        def job(t, args):
            output = 'Run {} with args {}\n'.format(t, ' '.join(args))
            output += subprocess.run(args, check=True, stderr=subprocess.PIPE, universal_newlines=True).stderr
            logging.debug(output)
        jobs.append(fuzz_pool.submit(job, t, args))
    for future in as_completed(jobs):
        future.result()
def merge_inputs(*, fuzz_pool, corpus, test_list, build_dir, merge_dir):
    logging.info('Merge the inputs in the passed dir into the seed_dir. Passed dir {}'.format(merge_dir))
    jobs = []
    for t in test_list:
        args = [os.path.join(build_dir, 'src', 'test', 'fuzz', t), '-merge=1', '-use_value_profile=1', os.path.join(corpus, t), os.path.join(merge_dir, t)]
        os.makedirs(os.path.join(corpus, t), exist_ok=True)
        os.makedirs(os.path.join(merge_dir, t), exist_ok=True)

        def job(t, args):
            output = 'Run {} with args {}\n'.format(t, ' '.join(args))
            output += subprocess.run(args, check=True, stderr=subprocess.PIPE, universal_newlines=True).stderr
            logging.debug(output)
        jobs.append(fuzz_pool.submit(job, t, args))
    for future in as_completed(jobs):
        future.result()