futures_mpi

Support for MPI evaluators.

class ema_workbench.em_framework.futures_mpi.MPIEvaluator(msis, n_processes=None, **kwargs)

Evaluator for experiments using MPI Pool Executor from mpi4py.

evaluate_experiments(experiments: Iterable[Experiment], callback: Callable, **kwargs)

Evaluate experiments using MPIPoolExecutor.

finalize()

Finalize the MPIPoolExecutor.

initialize()

Initialize the MPI pool.