queenbee.io.outputs.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.outputs.task.TaskPathReturn(*, type: ~typing.Literal['TaskPathReturn'] = 'TaskPathReturn', annotations: ~typing.Dict[str, ~typing.Any] = <factory>, name: str, description: str | None = None, path: str, required: bool = True)[source]

Bases: PathOutput

A Task output that returns a file or a folder output from a function or a DAG.

property is_artifact
model_config: ClassVar[ConfigDict] = {}

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

type: Literal['TaskPathReturn']
class queenbee.io.outputs.task.TaskReturn(*, type: ~typing.Literal['TaskReturn'] = 'TaskReturn', annotations: ~typing.Dict[str, ~typing.Any] = <factory>, name: str, description: str | None = None)[source]

Bases: GenericOutput

A Task return output that exposes the values from a function or a DAG.

property is_artifact
model_config: ClassVar[ConfigDict] = {}

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

type: Literal['TaskReturn']