pyworkflow.utils.mpi module

MPI utilities. runJobMPI and runJobMPISlave send and receive the commands to execute, in the given directory and with the given environment.

pyworkflow.utils.mpi.runJobMPI(programname, params, mpiComm, mpiDest, numberOfMpi=1, hostConfig=None, env=None, cwd=None, gpuList=None)[source]

Send the command to the MPI node in which it will be executed.


This slave will be receiving commands to execute until ‘None’ is received.

pyworkflow.utils.mpi.send(command, comm, dest, tag)[source]

Send command in a non-blocking way and raise exception on error.