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[Union[StepStringInput, StepIntegerInput, StepNumberInput, StepBooleanInput, StepFolderInput, StepFileInput, StepPathInput, StepArrayInput, StepJSONObjectInput]], outputs: List[Union[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[Union[StepStringInput, StepIntegerInput, StepNumberInput, StepBooleanInput, StepFolderInput, StepFileInput, StepPathInput, StepArrayInput, StepJSONObjectInput]]

job_id: str

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

status: RunStatusEnum

steps: Dict[str, StepStatus]

type: ConstrainedStrValue

class queenbee.job.run.RunStatusEnum(value)

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)

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[Union[StepStringInput, StepIntegerInput, StepNumberInput, StepBooleanInput, StepFolderInput, StepFileInput, StepPathInput, StepArrayInput, StepJSONObjectInput]], outputs: List[Union[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[Union[StepStringInput, StepIntegerInput, StepNumberInput, StepBooleanInput, StepFolderInput, StepFileInput, StepPathInput, StepArrayInput, StepJSONObjectInput]]

name: str

outbound_steps: List[str]

outputs: List[Union[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)

Bases: str, Enum

Enumaration of allowable status strings

failed = 'Failed'

running = 'Running'

scheduled = 'Scheduled'

skipped = 'Skipped'

succeeded = 'Succeeded'

unknown = 'Unknown'