fluiddyn.clusters.local

Local workstations as clusters (fluiddyn.clusters.local)

Provides:

class fluiddyn.clusters.local.ClusterLocal(check_scheduler=True, **kwargs)

Bases: Cluster

Works as a compatibility layer to execute submit scripts on local workstations as clusters with no job schedulers.

Instead uses POSIX commands:

• nohup and mpirun to launch jobs.

• timeout to set walltime..

submit_script(path, *args, **kwargs)

Submit a script. See submit_command for all possible arguments

submit_command(command, name_run='fluiddyn', nb_nodes=1, nb_cores_per_node=None, walltime='23:59:58', nb_mpi_processes=None, retain_script=True, omp_num_threads=1, ask=True, bash=True, interactive=False, **kwargs)

Submit a command.

Parameters:

commandstring

Command which executes the run

name_runstring

Name of the run to be displayed in SLURM queue

nb_nodesinteger

Number of nodes

nb_cores_per_nodeinteger

Defaults to a maximum is fixed for a cluster, as set by self.nb_cores_per_node.

walltimestring

Minimum walltime for the job

nb_mpi_processesNone, integer or "auto"

Number of MPI processes. Defaults to None (no MPI). If "auto", computed as nb_cores_per_node * nb_nodes.

omp_num_threadsinteger

Number of OpenMP threads

askboolean

Ask for user input to submit the jobscript or not

bashboolean

Submit jobscript via call_bash function

interactiveboolean

When True do not use cmd_launch to execute.

Functions

is_python_script(path)

Check whether path points to a file ending with .py extension.

Classes

ClusterLocal([check_scheduler])

Works as a compatibility layer to execute submit scripts on local workstations as clusters with no job schedulers.