jobflow_remote.jobs.state module

class jobflow_remote.jobs.state.FlowState(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

States of a Flow.

COMPLETED = 'COMPLETED'

FAILED = 'FAILED'

PAUSED = 'PAUSED'

READY = 'READY'

RUNNING = 'RUNNING'

STOPPED = 'STOPPED'

WAITING = 'WAITING'

classmethod from_jobs_states(jobs_states: list[JobState], leaf_states: list[JobState]) → FlowState

Generate the state of the Flow based on the states of the Jobs composing it, and in particular the states of the leaf Jobs.

Parameters:

• jobs_states – List of JobStates of all the Jobs in the Flow.

• leaf_states – List of JobStates of the leaf Jobs in the Flow.

Returns:

The state of the Flow.

Return type:

FlowState

class jobflow_remote.jobs.state.JobState(value, names=None, *, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: Enum

States of a Job.

BATCH_RUNNING = 'BATCH_RUNNING'

BATCH_SUBMITTED = 'BATCH_SUBMITTED'

CHECKED_OUT = 'CHECKED_OUT'

COMPLETED = 'COMPLETED'

DOWNLOADED = 'DOWNLOADED'

FAILED = 'FAILED'

PAUSED = 'PAUSED'

READY = 'READY'

REMOTE_ERROR = 'REMOTE_ERROR'

RUNNING = 'RUNNING'

STOPPED = 'STOPPED'

SUBMITTED = 'SUBMITTED'

TERMINATED = 'TERMINATED'

UPLOADED = 'UPLOADED'

USER_STOPPED = 'USER_STOPPED'

WAITING = 'WAITING'

property short_value: str