pyslurmutils.client.job_io.tcp_io.JobTcpIoHandler#

class pyslurmutils.client.job_io.tcp_io.JobTcpIoHandler(max_workers=None, client=None)[source]#

Bases: JobIoHandler

Parameters:

max_workers (Optional[int]) –

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)[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]#