pyslurmutils.client.job_io.file_io.JobFileIoHandler#

class pyslurmutils.client.job_io.file_io.JobFileIoHandler(client=None)[source]#

Bases: JobIoHandler

get_future(job_id)#
Parameters:

job_id (int) –

Return type:

Optional[Future]

get_job_ids()#

Only the jobs with active futures

Return type:

List[str]

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

  • wait (bool) –

  • cancel_futures (bool) –

Return type:

None

start_job_io(data, infile, outfile)[source]#

Returns the script, environment variables and pending result parameters

Parameters:

  • data (Any) –

  • infile (str) –

  • outfile (str) –

Return type:

Tuple[str, dict, Future]

worker_count()[source]#