flytekit.models.types

Class	Description
`Error`
`LiteralType`
`OutputReference`
`SchemaType`
`SimpleType`
`StructuredDatasetType`
`TypeStructure`	Models _types_pb2.
`UnionType`	Models _types_pb2.

flytekit.models.types.Error

Parameters

        
    
class Error(
    failed_node_id: str,
    message: str,
)

Parameter	Type	Description
`failed_node_id`	`str`
`message`	`str`

Properties

Property	Type	Description
`failed_node_id`	`str`
`is_empty`	`None`
`message`	`str`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    pb2_object: flyteidl.core.types_pb2.Error,
) -> Error

Parameter	Type	Description
`pb2_object`	`flyteidl.core.types_pb2.Error`

Returns: Error

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.types.LiteralType

Parameters

        
    
class LiteralType(
    simple,
    schema,
    collection_type,
    map_value_type,
    blob,
    enum_type,
    union_type,
    structured_dataset_type,
    metadata,
    structure,
    annotation,
)

This is a oneof message, only one of the kwargs may be set, representing one of the Flyte types.

Parameter	Type	Description
`simple`
`schema`
`collection_type`
`map_value_type`
`blob`
`enum_type`
`union_type`
`structured_dataset_type`
`metadata`
`structure`
`annotation`

Properties

Property	Type	Description
`annotation`	`flytekit.models.annotation.TypeAnnotation`
`blob`	`flytekit.models.core.types.BlobType`
`collection_type`	`LiteralType`	The collection value type
`enum_type`	`flytekit.models.core.types.EnumType`
`is_empty`	`None`
`map_value_type`	`LiteralType`	The Value for a dictionary. Key is always string
`metadata`	`None`
`schema`	`flytekit.models.types.SchemaType`
`simple`	`flytekit.models.types.SimpleType`
`structure`	`flytekit.models.types.TypeStructure`
`structured_dataset_type`	`flytekit.models.types.StructuredDatasetType`
`union_type`	`flytekit.models.types.UnionType`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    proto,
)

Parameter	Type	Description
`proto`

Returns: LiteralType

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

Returns: flyteidl.core.types_pb2.LiteralType

flytekit.models.types.OutputReference

Parameters

        
    
class OutputReference(
    node_id,
    var,
    attr_path: typing.List[typing.Union[str, int]],
)

A reference to an output produced by a node. The type can be retrieved -and validated- from the underlying interface of the node.

Parameter	Type	Description
`node_id`
`var`
`attr_path`	`typing.List[typing.Union[str, int]]`

Properties

Property	Type	Description
`attr_path`	`typing.List[typing.Union[str, int]]`	The attribute path the promise will be resolved with.
`is_empty`	`None`
`node_id`	`None`	Node id must exist at the graph layer.
`var`	`None`	Variable name must refer to an output variable for the node.

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    pb2_object,
)

Parameter	Type	Description
`pb2_object`

Returns: OutputReference

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

Returns: flyteidl.core.types.OutputReference

flytekit.models.types.SchemaType

Parameters

        
    
class SchemaType(
    columns,
)

Parameter	Type	Description
`columns`

Properties

Property	Type	Description
`columns`	`None`	A list of columns defining the underlying data frame.
`is_empty`	`None`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    proto,
)

Parameter	Type	Description
`proto`

Returns: SchemaType

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

Returns: flyteidl.core.types_pb2.SchemaType

flytekit.models.types.SimpleType

flytekit.models.types.StructuredDatasetType

Parameters

        
    
class StructuredDatasetType(
    columns: typing.List[flytekit.models.types.StructuredDatasetType.DatasetColumn],
    format: str,
    external_schema_type: str,
    external_schema_bytes: bytes,
)

Parameter	Type	Description
`columns`	`typing.List[flytekit.models.types.StructuredDatasetType.DatasetColumn]`
`format`	`str`
`external_schema_type`	`str`
`external_schema_bytes`	`bytes`

Properties

Property	Type	Description
`columns`	`typing.List[flytekit.models.types.StructuredDatasetType.DatasetColumn]`
`external_schema_bytes`	`bytes`
`external_schema_type`	`str`
`format`	`str`
`is_empty`	`None`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    proto: flyteidl.core.types_pb2.StructuredDatasetType,
) -> flyteidl.core.types_pb2.StructuredDatasetType

Parameter	Type	Description
`proto`	`flyteidl.core.types_pb2.StructuredDatasetType`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.types.TypeStructure

Models _types_pb2.TypeStructure

Parameters

        
    
class TypeStructure(
    tag: str,
    dataclass_type: typing.Dict[str, ForwardRef('LiteralType')],
)

Parameter	Type	Description
`tag`	`str`
`dataclass_type`	`typing.Dict[str, ForwardRef('LiteralType')]`

Properties

Property	Type	Description
`dataclass_type`	`typing.Dict[str, ForwardRef('LiteralType')]`
`is_empty`	`None`
`tag`	`str`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    proto: flyteidl.core.types_pb2.TypeStructure,
)

Parameter	Type	Description
`proto`	`flyteidl.core.types_pb2.TypeStructure`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.types.UnionType

Models _types_pb2.UnionType

Parameters

        
    
class UnionType(
    variants: typing.List[ForwardRef('LiteralType')],
)

Parameter	Type	Description
`variants`	`typing.List[ForwardRef('LiteralType')]`

Properties

Property	Type	Description
`is_empty`	`None`
`variants`	`typing.List[ForwardRef('LiteralType')]`

Methods

Method	Description
`from_flyte_idl()`
`serialize_to_string()`
`short_string()`
`to_flyte_idl()`

from_flyte_idl()

        
    
def from_flyte_idl(
    proto: flyteidl.core.types_pb2.UnionType,
)

Parameter	Type	Description
`proto`	`flyteidl.core.types_pb2.UnionType`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()