pyslurmutils.client.job_io.base_io.JobIoHandler#

class pyslurmutils.client.job_io.base_io.JobIoHandler(client=None)[source]#

Bases: object

get_future(job_id)[source]#
Parameters:

job_id (int) –

Return type:

Optional[Future]

get_job_ids()[source]#

Only the jobs with active futures

Return type:

List[str]

shutdown(wait=True, cancel_futures=False)[source]#
Parameters:

  • wait (bool) –

  • cancel_futures (bool) –

Return type:

None

start_job_io(data, timeout=None)[source]#

Returns the script, environment variables and pending result parameters

Parameters:

  • data (Any) –

  • timeout (Optional[Number]) –

Return type:

Tuple[str, dict, Future]

worker_count()[source]#