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.
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.