queenbee.io.inputs.task module¶

Argument and Return objects for tasks.

Task argument and return objects provide the interface to connect:

DAG inputs to function inputs

DAG inputs to DAG inputs – for nested DAGs

function outputs to following function inputs

function outputs to DAG outputs

DAG outputs to DAG outputs – for nested DAGs

class queenbee.io.inputs.task.TaskArgument(*, type: ConstrainedStrValue = 'TaskArgument', annotations: Dict[str, Any] = None, name: str, **extra_data: Any)[source]¶

Bases: BaseModel

Task argument for receiving inputs that are not files or folders.

from_: Union[InputReference, TaskReference, ItemReference, ValueReference]¶

property is_artifact¶

property is_parameter¶

name: str¶

type: ConstrainedStrValue¶

class queenbee.io.inputs.task.TaskPathArgument(*, type: ConstrainedStrValue = 'TaskPathArgument', annotations: Dict[str, Any] = None, name: str, sub_path: str = None, **extra_data: Any)[source]¶

Bases: BaseModel

from_: Union[InputFileReference, InputFolderReference, InputPathReference, TaskFileReference, TaskFolderReference, TaskPathReference, ValueFileReference, ValueFolderReference]¶

property is_artifact¶

property is_parameter¶

name: str¶

sub_path: str¶

type: ConstrainedStrValue¶