queenbee.io.outputs.dag module¶

Queenbee output types for a DAG.

class queenbee.io.outputs.dag.DAGArrayOutput(*, type: ConstrainedStrValue = 'DAGArrayOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, items_type: ItemType = ItemType.String, **extra_data: Any)[source]¶

Bases: DAGStringOutput

DAG array output.

This output loads the content from a JSON file which must be a JSON Array.

items_type: ItemType¶

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGBooleanOutput(*, type: ConstrainedStrValue = 'DAGBooleanOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: DAGStringOutput

DAG boolean output.

This output loads the content from a file as a boolean.

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGFileOutput(*, type: ConstrainedStrValue = 'DAGFileOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: _DAGArtifactOutput

DAG file output.

from_: Union[TaskReference, FileReference]¶

property is_artifact¶

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGFolderOutput(*, type: ConstrainedStrValue = 'DAGFolderOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: _DAGArtifactOutput

DAG folder output.

from_: Union[TaskReference, FolderReference]¶

property is_artifact¶

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGGenericOutput(*, type: ConstrainedStrValue = 'DAGGenericOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, **extra_data: Any)[source]¶

Bases: FromOutput

DAG generic output.

In most cases, you should not be using the generic output unless you need a dynamic output that changes its type in different platforms because of returning different objects in handler.

alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]]¶

classmethod create_empty_handler_list(v)[source]¶

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGIntegerOutput(*, type: ConstrainedStrValue = 'DAGIntegerOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: DAGStringOutput

DAG integer output.

This output loads the content from a file as an integer.

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGJSONObjectOutput(*, type: ConstrainedStrValue = 'DAGJSONObjectOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: DAGStringOutput

DAG object output.

This output loads the content from a file as a JSON object.

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGNumberOutput(*, type: ConstrainedStrValue = 'DAGNumberOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: DAGStringOutput

DAG number output.

This output loads the content from a file as a floating number.

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGPathOutput(*, type: ConstrainedStrValue = 'DAGPathOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: _DAGArtifactOutput

DAG path output.

from_: Union[TaskReference, FileReference, FolderReference]¶

property is_artifact¶

type: ConstrainedStrValue¶

class queenbee.io.outputs.dag.DAGStringOutput(*, type: ConstrainedStrValue = 'DAGStringOutput', annotations: Dict[str, Any] = None, name: str, description: str = None, alias: List[Union[DAGGenericOutputAlias, DAGStringOutputAlias, DAGIntegerOutputAlias, DAGNumberOutputAlias, DAGBooleanOutputAlias, DAGFolderOutputAlias, DAGFileOutputAlias, DAGPathOutputAlias, DAGArrayOutputAlias, DAGJSONObjectOutputAlias, DAGLinkedOutputAlias]] = None, required: bool = True, **extra_data: Any)[source]¶

Bases: DAGFileOutput

DAG string output.

This output loads the content from a file as a string.

property is_artifact¶

type: ConstrainedStrValue¶