- execute_parallel(fun, execution_iter, n_workers=None, **kwargs)
Execute concurrent futures with an established cluster.
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.
results (list) – List of futures results.