pipeline.infrastructure.mpihelpers

Functions

is_mpi_ready()
mpiexec(tier0_executable)	Execute a pipeline task.
parse_mpi_input_parameter(input_arg)

Classes

AsyncTask(executable)
Executable()
SyncTask(task[, executor])
Tier0FunctionCall(fn, *args, **kwargs)
Tier0JobRequest(creator_fn, job_args)
Tier0PipelineTask(task_cls, task_args, …)