rex.utilities.execution.execute_parallel

execute_parallel(fun, execution_iter, n_workers=None, **kwargs)[source]

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.