flytekit.models.node_execution

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

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

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

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def 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],
):

def from_flyte_idl(
    p,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

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

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

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

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()