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: ConstrainedStrValue = 'TaskPathReturn', annotations: Dict[str, Any] = None, name: str, description: str = 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¶

type: ConstrainedStrValue¶

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

Bases: GenericOutput

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

property is_artifact¶

type: ConstrainedStrValue¶