NEDAS.job_submitters.oar module

class NEDAS.job_submitters.oar.OARJobSubmitter(**kwargs)

Bases: HPCJobSubmitter

JobSubmitter Class customized for OAR schedulers

property nproc_avail

Number of available processors on a host machine This should be redefined in subclasses to machine specific behavior

property node_list_avail

property nnode_avail

Number of available compute nodes on a host machine

property ppn_avail

Number of available processors per compute node

update_node_file()

property execute_command

Execute command for running the job on the host machine, replacing ‘JOB_EXECUTE’ in ‘commands’

property job_array_index_name

Job array index variable name for the host machine, replacing ‘JOB_ARRAY_INDEX’ in ‘commands’

property in_job_allocation: bool

Determines if a job allocation is already availalbe on the HPC If so, the job can be run as a sub step directly, otherwise will need to submit it to the queue.

run_job_as_step(commands)

Run ‘commands’ from within a job allocation Use nproc processors starting from the offset+1 processor of the allocation

submit_job_and_monitor(commands)

Submit ‘commands’ as a job script to the scheduler on HPC and monitor for its completion.

job_submit_cmd()

get_job_id(stdout)

check_job_status()