pyslurmutils.client.rest.base.SlurmBaseRestClient#

class pyslurmutils.client.rest.base.SlurmBaseRestClient(url='', user_name='', token='', parameters=None, log_directory=None, request_options=None)[source]#

Bases: object

Low-level SLURM API to submit, cancel and monitor jobs. This class does not contain any job-related state.

Parameters:

  • url (str) –

  • user_name (str) –

  • token (str) –

  • parameters (Optional[dict]) –

  • log_directory (Optional[str]) –

  • request_options (Optional[dict]) –

VERSION = '0.0.37'#
cancel_job(job_id, request_options=None)[source]#
Parameters:

  • job_id (int) –

  • request_options (Optional[dict]) –

Return type:

None

clean_job_artifacts(job_id, raise_on_error=False, properties=None, **kw)[source]#
Parameters:

  • job_id (int) –

  • properties (Optional[dict]) –

cleanup(wait=True)[source]#
Parameters:

wait (bool) –

Return type:

None

delete(path, request_options=None, error_msg=None, raise_on_error=True)[source]#
Parameters:

  • path (str) –

  • request_options (Optional[dict]) –

  • error_msg (Optional[str]) –

  • raise_on_error (bool) –

Return type:

dict

get(path, request_options=None, error_msg=None, raise_on_error=True)[source]#
Parameters:

  • path (str) –

  • request_options (Optional[dict]) –

  • error_msg (Optional[str]) –

  • raise_on_error (bool) –

Return type:

dict

get_all_job_properties(raise_on_error=True, request_options=None, filter=None, update_time=None)[source]#
Parameters:

request_options (Optional[dict]) –

Return type:

List[dict]

get_headers()[source]#
Return type:

dict

get_job_properties(job_id, raise_on_error=True, request_options=None)[source]#
Parameters:

  • job_id (int) –

  • request_options (Optional[dict]) –

Return type:

Optional[dict]

get_stdout_stderr(job_id, **kw)[source]#
Parameters:

job_id (int) –

Return type:

Tuple[StdInfo, StdInfo]

post(path, json=None, request_options=None, raise_on_error=True, error_msg=None)[source]#
Parameters:

  • path (str) –

  • json (Optional[dict]) –

  • request_options (Optional[dict]) –

  • raise_on_error (bool) –

  • error_msg (Optional[str]) –

Return type:

dict

server_has_api(request_options=None)[source]#
Parameters:

request_options (Optional[dict]) –

Return type:

bool

submit_job(script, parameters=None, metadata=None, request_options=None)[source]#

Returns the SLURM job ID

Parameters:

  • script (str) –

  • parameters (Optional[dict]) –

  • metadata (Union[str, dict, None]) –

  • request_options (Optional[dict]) –

Return type:

int