queenbee.job.run module

Queenbee run class.

A Run contains the status of an individual recipe being executed

class queenbee.job.run.RunStatus(*, type: ConstrainedStrValue = 'RunStatus', annotations: Dict[str, Any] = None, inputs: List[StepStringInput | StepIntegerInput | StepNumberInput | StepBooleanInput | StepFolderInput | StepFileInput | StepPathInput | StepArrayInput | StepJSONObjectInput], outputs: List[StepStringOutput | StepIntegerOutput | StepNumberOutput | StepBooleanOutput | StepFolderOutput | StepFileOutput | StepPathOutput | StepArrayOutput | StepJSONObjectOutput], message: str = None, started_at: datetime, finished_at: datetime = None, source: str = None, api_version: ConstrainedStrValue = 'v1beta1', id: str, job_id: str, entrypoint: str = None, status: RunStatusEnum = RunStatusEnum.unknown, steps: Dict[str, StepStatus] = {})

Bases: BaseStatus

Job Status.

api_version: ConstrainedStrValue

entrypoint: str

id: str

inputs: List[StepStringInput | StepIntegerInput | StepNumberInput | StepBooleanInput | StepFolderInput | StepFileInput | StepPathInput | StepArrayInput | StepJSONObjectInput]

job_id: str

outputs: List[StepStringOutput | StepIntegerOutput | StepNumberOutput | StepBooleanOutput | StepFolderOutput | StepFileOutput | StepPathOutput | StepArrayOutput | StepJSONObjectOutput]

status: RunStatusEnum

steps: Dict[str, StepStatus]

type: ConstrainedStrValue

class queenbee.job.run.RunStatusEnum(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: str, Enum

Enumaration of allowable status strings

cancelled = 'Cancelled'

created = 'Created'

failed = 'Failed'

post_processing = 'Post-Processing'

running = 'Running'

scheduled = 'Scheduled'

succeeded = 'Succeeded'

unknown = 'Unknown'

class queenbee.job.run.StatusType(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: str, Enum

Type enum for status type.

Container = 'Container'

DAG = 'DAG'

Function = 'Function'

Loop = 'Loop'

Unknown = 'Unknown'

class queenbee.job.run.StepStatus(*, type: ConstrainedStrValue = 'StepStatus', annotations: Dict[str, Any] = None, inputs: List[StepStringInput | StepIntegerInput | StepNumberInput | StepBooleanInput | StepFolderInput | StepFileInput | StepPathInput | StepArrayInput | StepJSONObjectInput], outputs: List[StepStringOutput | StepIntegerOutput | StepNumberOutput | StepBooleanOutput | StepFolderOutput | StepFileOutput | StepPathOutput | StepArrayOutput | StepJSONObjectOutput], message: str = None, started_at: datetime, finished_at: datetime = None, source: str = None, id: str, name: str, status: StepStatusEnum = StepStatusEnum.unknown, status_type: StatusType, template_ref: str, command: str = None, boundary_id: str = None, children_ids: List[str], outbound_steps: List[str])

Bases: BaseStatus

The Status of a Job Step

boundary_id: str

children_ids: List[str]

command: str

id: str

inputs: List[StepStringInput | StepIntegerInput | StepNumberInput | StepBooleanInput | StepFolderInput | StepFileInput | StepPathInput | StepArrayInput | StepJSONObjectInput]

name: str

outbound_steps: List[str]

outputs: List[StepStringOutput | StepIntegerOutput | StepNumberOutput | StepBooleanOutput | StepFolderOutput | StepFileOutput | StepPathOutput | StepArrayOutput | StepJSONObjectOutput]

status: StepStatusEnum

status_type: StatusType

template_ref: str

type: ConstrainedStrValue

class queenbee.job.run.StepStatusEnum(value, names=<not given>, *values, module=None, qualname=None, type=None, start=1, boundary=None)

Bases: str, Enum

Enumaration of allowable status strings

failed = 'Failed'

running = 'Running'

scheduled = 'Scheduled'

skipped = 'Skipped'

succeeded = 'Succeeded'

unknown = 'Unknown'