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

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.