Class ClientConnection

Declaration

class ClientConnection

▷ def __init__(self, directory: Optional[str] = None)
source link
▷ def forget_job(self, job_id: JobId)
source link
▷ def get_failed_tasks(self, job_ids: Sequence[JobId]) -> TaskFailureMap
source link
▷ def stop_server(self)
source link
▷ def submit_job(self, job_description: JobDescription) -> JobId
source link
▷ def wait_for_jobs(self, job_ids: Sequence[JobId], callback) -> List[JobId]
Blocks until jobs are finished. Returns the number of failed tasks
source link