queenbee.job.job module¶
- class queenbee.job.job.Job(*, type: ConstrainedStrValue = 'Job', annotations: Dict[str, Any] = None, api_version: ConstrainedStrValue = 'v1beta1', source: str, arguments: List[List[Union[JobArgument, JobPathArgument]]] = None, name: str = None, description: str = None, labels: Dict[str, str] = None)[source]¶
Bases:
BaseModelQueenbee Job.
A Job is an object to submit a list of arguments to execute a Queenbee recipe.
- api_version: ConstrainedStrValue¶
- arguments: List[List[Union[JobArgument, JobPathArgument]]]¶
- description: str¶
- labels: Dict[str, str]¶
- name: str¶
- populate_default_arguments(inputs: List[Union[DAGGenericInput, DAGStringInput, DAGIntegerInput, DAGNumberInput, DAGBooleanInput, DAGFolderInput, DAGFileInput, DAGPathInput, DAGArrayInput, DAGJSONObjectInput]])[source]¶
- source: str¶
- type: ConstrainedStrValue¶
- validate_arguments(inputs: List[Union[DAGGenericInput, DAGStringInput, DAGIntegerInput, DAGNumberInput, DAGBooleanInput, DAGFolderInput, DAGFileInput, DAGPathInput, DAGArrayInput, DAGJSONObjectInput]])[source]¶
- class queenbee.job.job.JobStatus(*, type: ConstrainedStrValue = 'JobStatus', annotations: Dict[str, Any] = None, api_version: ConstrainedStrValue = 'v1beta1', id: str, status: JobStatusEnum = JobStatusEnum.unknown, message: str = None, started_at: datetime, finished_at: datetime = None, source: str = None, runs_pending: int = 0, runs_running: int = 0, runs_completed: int = 0, runs_failed: int = 0, runs_cancelled: int = 0)[source]¶
Bases:
BaseModelParametric Job Status.
- api_version: ConstrainedStrValue¶
- finished_at: datetime¶
- id: str¶
- message: str¶
- runs_cancelled: int¶
- runs_completed: int¶
- runs_failed: int¶
- runs_pending: int¶
- runs_running: int¶
- source: str¶
- started_at: datetime¶
- status: JobStatusEnum¶
- type: ConstrainedStrValue¶