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)

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

pyworkflow.utils.mpi.runJobMPISlave(mpiComm)

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

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

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