flytekit.models.node_execution

Class	Description
`DynamicWorkflowNodeMetadata`
`NodeExecution`
`NodeExecutionClosure`
`TaskNodeMetadata`
`WorkflowNodeMetadata`

flytekit.models.node_execution.DynamicWorkflowNodeMetadata

Parameters

        
    
class DynamicWorkflowNodeMetadata(
    id: flytekit.models.core.identifier.Identifier,
    compiled_workflow: flytekit.models.core.compiler.CompiledWorkflowClosure,
)

Parameter	Type	Description
`id`	`flytekit.models.core.identifier.Identifier`
`compiled_workflow`	`flytekit.models.core.compiler.CompiledWorkflowClosure`

Properties

Property	Type	Description
`compiled_workflow`	`None`
`id`	`None`
`is_empty`	`None`

Methods

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

from_flyte_idl()

        
    
def from_flyte_idl(
    p: flyteidl.admin.node_execution_pb2.DynamicWorkflowNodeMetadata,
) -> DynamicWorkflowNodeMetadata

Parameter	Type	Description
`p`	`flyteidl.admin.node_execution_pb2.DynamicWorkflowNodeMetadata`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.node_execution.NodeExecution

Parameters

        
    
class NodeExecution(
    id,
    input_uri,
    closure,
    metadata: flyteidl.admin.node_execution_pb2.NodeExecutionMetaData,
)

Parameter	Type	Description
`id`
`input_uri`
`closure`
`metadata`	`flyteidl.admin.node_execution_pb2.NodeExecutionMetaData`

Properties

Property	Type	Description
`closure`	`None`
`id`	`None`
`input_uri`	`None`
`is_empty`	`None`
`metadata`	`None`

Methods

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

from_flyte_idl()

        
    
def from_flyte_idl(
    p: flyteidl.admin.node_execution_pb2.NodeExecution,
) -> NodeExecution

Parameter	Type	Description
`p`	`flyteidl.admin.node_execution_pb2.NodeExecution`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.node_execution.NodeExecutionClosure

Parameters

        
    
class NodeExecutionClosure(
    phase,
    started_at,
    duration,
    output_uri,
    deck_uri,
    error,
    workflow_node_metadata: typing.Optional[flytekit.models.node_execution.WorkflowNodeMetadata],
    task_node_metadata: typing.Optional[flytekit.models.node_execution.TaskNodeMetadata],
    created_at: typing.Optional[datetime.datetime],
    updated_at: typing.Optional[datetime.datetime],
)

Parameter	Type	Description
`phase`
`started_at`
`duration`
`output_uri`
`deck_uri`
`error`
`workflow_node_metadata`	`typing.Optional[flytekit.models.node_execution.WorkflowNodeMetadata]`
`task_node_metadata`	`typing.Optional[flytekit.models.node_execution.TaskNodeMetadata]`
`created_at`	`typing.Optional[datetime.datetime]`
`updated_at`	`typing.Optional[datetime.datetime]`

Properties

Property	Type	Description
`created_at`	`None`
`deck_uri`	`None`
`duration`	`None`
`error`	`None`
`is_empty`	`None`
`output_uri`	`None`
`phase`	`None`
`started_at`	`None`
`target_metadata`	`None`
`task_node_metadata`	`None`
`updated_at`	`None`
`workflow_node_metadata`	`None`

Methods

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

from_flyte_idl()

        
    
def from_flyte_idl(
    p,
)

Parameter	Type	Description
`p`

Returns: NodeExecutionClosure

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

Returns: flyteidl.admin.node_execution_pb2.NodeExecutionClosure

flytekit.models.node_execution.TaskNodeMetadata

Parameters

        
    
class TaskNodeMetadata(
    cache_status: int,
    catalog_key: flytekit.models.core.catalog.CatalogMetadata,
)

Parameter	Type	Description
`cache_status`	`int`
`catalog_key`	`flytekit.models.core.catalog.CatalogMetadata`

Properties

Property	Type	Description
`cache_status`	`None`
`catalog_key`	`None`
`is_empty`	`None`

Methods

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

from_flyte_idl()

        
    
def from_flyte_idl(
    p: flyteidl.admin.node_execution_pb2.TaskNodeMetadata,
) -> TaskNodeMetadata

Parameter	Type	Description
`p`	`flyteidl.admin.node_execution_pb2.TaskNodeMetadata`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()

flytekit.models.node_execution.WorkflowNodeMetadata

Parameters

        
    
class WorkflowNodeMetadata(
    execution_id: flytekit.models.core.identifier.WorkflowExecutionIdentifier,
)

Parameter	Type	Description
`execution_id`	`flytekit.models.core.identifier.WorkflowExecutionIdentifier`

Properties

Property	Type	Description
`execution_id`	`None`
`is_empty`	`None`

Methods

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

from_flyte_idl()

        
    
def from_flyte_idl(
    p: flyteidl.admin.node_execution_pb2.WorkflowNodeMetadata,
) -> WorkflowNodeMetadata

Parameter	Type	Description
`p`	`flyteidl.admin.node_execution_pb2.WorkflowNodeMetadata`

serialize_to_string()

        
    
def serialize_to_string()

short_string()

        
    
def short_string()

Returns: Text

to_flyte_idl()

        
    
def to_flyte_idl()