ai2_kit.core.job module#

class ai2_kit.core.job.JobFuture[source]#

Bases: IFuture[JobState]

abstract cancel()[source]#

abstract get_job_state() → JobState[source]#

abstract is_success() → bool[source]#

abstract resubmit() → JobFuture[source]#

class ai2_kit.core.job.JobState(value)[source]#

Bases: bytes, Enum

Defines a set of states that a job can be in

CANCELLED = 3#

COMPLETED = 4#

FAILED = 5#

HELD = 7#

PENDING = 1#

RUNNING = 2#

TIMEOUT = 6#

UNKNOWN = 0#

status_name: str#

terminal: bool#

value: int#

exception ai2_kit.core.job.TimeoutError[source]#: Bases: RuntimeError

async ai2_kit.core.job.gather_jobs(jobs: List[JobFuture], timeout=inf, max_tries: int = 1, raise_error=True) → List[JobState][source]#