def run_worker_pool(job_handler, host="<STR_LIT:localhost>", port=<NUM_LIT>,<EOL>*, max_workers=None):
if max_workers is None:<EOL><INDENT>max_workers = multiprocessing.cpu_count()<EOL><DEDENT>processes = []<EOL>for _ in range(max_workers):<EOL><INDENT>p = multiprocessing.Process(target=worker_main,<EOL>args=(job_handler, host, port))<EOL>p.start()<EOL>processes.append(p)<EOL><DEDENT>logger.debug("<STR_LIT>")<EOL>for p in processes:<EOL><INDENT>p.join()<EOL><DEDENT>logger.debug("<STR_LIT>")<EOL>
Runs a pool of workers which connect to a remote HighFive master and begin
executing calls.