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: ~typing.Literal['TaskArgument'] = 'TaskArgument', annotations: ~typing.Dict[str, ~typing.Any] | None = <factory>, name: str, from_: ~queenbee.io.reference.InputReference | ~queenbee.io.reference.TaskReference | ~queenbee.io.reference.ItemReference | ~queenbee.io.reference.ValueReference)[source]¶

Bases: BaseModel

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

from_: InputReference | TaskReference | ItemReference | ValueReference¶

property is_artifact¶

property is_parameter¶

model_config: ClassVar[ConfigDict] = {}¶: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

name: str¶

type: Literal['TaskArgument']¶

class queenbee.io.inputs.task.TaskPathArgument(*, type: ~typing.Literal['TaskPathArgument'] = 'TaskPathArgument', annotations: ~typing.Dict[str, ~typing.Any] | None = <factory>, name: str, from_: ~queenbee.io.reference.InputFileReference | ~queenbee.io.reference.InputFolderReference | ~queenbee.io.reference.InputPathReference | ~queenbee.io.reference.TaskFileReference | ~queenbee.io.reference.TaskFolderReference | ~queenbee.io.reference.TaskPathReference | ~queenbee.io.reference.ValueFileReference | ~queenbee.io.reference.ValueFolderReference, sub_path: str | None = None)[source]¶

Bases: BaseModel

from_: InputFileReference | InputFolderReference | InputPathReference | TaskFileReference | TaskFolderReference | TaskPathReference | ValueFileReference | ValueFolderReference¶

property is_artifact¶

property is_parameter¶

model_config: ClassVar[ConfigDict] = {}¶: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

name: str¶

sub_path: str | None¶

type: Literal['TaskPathArgument']¶