shapepipe.pipeline.mpi_run

shapepipe.pipeline.mpi_run

MPI RUN.

This module includes functions for handling the distribution of MPI jobs.

Author

Samuel Farrens <samuel.farrens@cea.fr>

split_mpi_jobs(jobs, batch_size)[source]

Split MPI Jobs.

Split the number of MPI jobs over the number of processes.

Parameters

  • jobs (list) – List of MPI jobs

  • batch_size (int) – Batch size

Returns

Split list of jobs

Return type

list

submit_mpi_jobs(jobs, config, timeout, run_dirs, module_runner, worker_log, verbose)[source]

Submit MPI Jobs.

This method distributes the jobs to the workers using MPI.

previous

shapepipe.pipeline.job_handler

next

shapepipe.pipeline.run_log