hpcflow.sdk.submission.schedulers.Scheduler#

class hpcflow.sdk.submission.schedulers.Scheduler(submit_cmd=None, show_cmd=None, del_cmd=None, js_cmd=None, login_nodes_cmd=None, array_switch=None, array_item_var=None, *args, **kwargs)#

Bases: NullScheduler

Methods

format_switch

get_version_info

is_jobscript_active

Query if a jobscript is running/pending.

is_num_cores_supported

parse_submission_output

wait_for_jobscripts

Attributes

DEFAULT_LOGIN_NODES_CMD

DEFAULT_LOGIN_NODE_MATCH

DEFAULT_SHEBANG_ARGS

DEFAULT_SHELL_ARGS

DEFAULT_LOGIN_NODES_CMD = None#
DEFAULT_LOGIN_NODE_MATCH = '*login*'#
DEFAULT_SHEBANG_ARGS = ''#
DEFAULT_SHELL_ARGS = ''#
format_switch(switch)#
get_version_info()#
is_jobscript_active(job_ID)#

Query if a jobscript is running/pending.

Parameters:

job_ID (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

wait_for_jobscripts(js_refs)#
Parameters:

js_refs (List[Any]) –

Return type:

None