matflow.DirectPosix#

class matflow.DirectPosix(*args, **kwargs)#

Bases: DirectPosix

Methods

cancel_jobs

get_job_state_info

Query the scheduler to get the states of all of this user's jobs, optionally filtering by specified job IDs.

get_submit_command

get_version_info

is_jobscript_active

Query if a jobscript is running.

is_num_cores_supported

parse_submission_output

process_resources

Perform scheduler-specific processing to the element resources.

wait_for_jobscripts

Wait until the specified jobscripts have completed.

Attributes

DEFAULT_SHEBANG_ARGS

DEFAULT_SHELL_ARGS

DEFAULT_SHELL_EXECUTABLE

app

unique_properties

DEFAULT_SHEBANG_ARGS = ''#
DEFAULT_SHELL_ARGS = ''#
DEFAULT_SHELL_EXECUTABLE = '/bin/bash'#
app = App(name='MatFlow', version='0.3.0a129')#
cancel_jobs(js_refs, jobscripts=None)#
Parameters:
get_job_state_info(js_refs, num_js_elements)#

Query the scheduler to get the states of all of this user’s jobs, optionally filtering by specified job IDs.

Jobs that are not in the scheduler’s status output will not appear in the output of this method.

Parameters:
Return type:

Dict[int, Dict[int, JobscriptElementState]]

get_submit_command(shell, js_path, deps)#
Parameters:
Return type:

List[str]

get_version_info()#
is_jobscript_active(process_ID, process_cmdline)#

Query if a jobscript is running.

Note that a “running” jobscript might be waiting on upstream jobscripts to complete.

Parameters:

  • process_ID (int) –

  • process_cmdline (List[str]) –

static is_num_cores_supported(num_cores, core_range)#
Parameters:

core_range (List[int]) –

parse_submission_output(stdout)#
Parameters:

stdout (str) –

Return type:

None

classmethod process_resources(resources, scheduler_config)#

Perform scheduler-specific processing to the element resources.

Note: this mutates resources.

Parameters:

scheduler_config (Dict) –

Return type:

None

property unique_properties#
classmethod wait_for_jobscripts(js_refs, callback=None)#

Wait until the specified jobscripts have completed.

Parameters:
Return type:

None