rex.utilities.execution.execute_parallel

execute_parallel(fun, execution_iter, n_workers=None, **kwargs)

Execute concurrent futures with an established cluster.

Parameters:

• fun (function) – Python function object that will be submitted to futures. See downstream execution methods for arg passing structure.

• execution_iter (iter) – Python iterator that controls the futures submitted in parallel.

• n_workers (int) – Number of workers to run in parallel

• **kwargs (dict) – Key word arguments passed to the fun.

Returns:

results (list) – List of futures results.