flytekit.models.execution

class AbortMetadata(
    cause: str,
    principal: str,
)

def from_flyte_idl(
    pb2_object: flyteidl.admin.execution_pb2.AbortMetadata,
) -> AbortMetadata

def serialize_to_string()

def short_string()

def to_flyte_idl()

class ClusterAssignment(
    cluster_pool,
)

def from_flyte_idl(
    p,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class Execution(
    id,
    spec,
    closure,
)

def from_flyte_idl(
    pb,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class ExecutionClosure(
    phase: int,
    started_at: datetime.datetime,
    duration: datetime.timedelta,
    error: typing.Optional[_core_execution.ExecutionError],
    outputs: typing.Optional[LiteralMapBlob],
    abort_metadata: typing.Optional[AbortMetadata],
    created_at: typing.Optional[datetime.datetime],
    updated_at: typing.Optional[datetime.datetime],
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class ExecutionMetadata(
    mode: int,
    principal: str,
    nesting: int,
    scheduled_at: Optional[datetime.datetime],
    parent_node_execution: Optional[_identifier.NodeExecutionIdentifier],
    reference_execution: Optional[_identifier.WorkflowExecutionIdentifier],
    system_metadata: Optional[SystemMetadata],
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class ExecutionSpec(
    launch_plan,
    metadata,
    notifications,
    disable_all,
    labels,
    annotations,
    auth_role,
    raw_output_data_config,
    max_parallelism: Optional[int],
    security_context: Optional[security.SecurityContext],
    overwrite_cache: Optional[bool],
    interruptible: Optional[bool],
    envs: Optional[_common_models.Envs],
    tags: Optional[typing.List[str]],
    cluster_assignment: Optional[ClusterAssignment],
    execution_cluster_label: Optional[ExecutionClusterLabel],
)

def from_flyte_idl(
    p,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class LiteralMapBlob(
    values,
    uri,
)

def from_flyte_idl(
    pb,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class NodeExecutionGetDataResponse(
    args,
    dynamic_workflow: typing.Optional[DynamicWorkflowNodeMetadata],
    kwargs,
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class NotificationList(
    notifications,
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class SystemMetadata(
    execution_cluster: str,
)

def from_flyte_idl(
    pb2_object: flyteidl.admin.execution_pb2.SystemMetadata,
) -> SystemMetadata

def serialize_to_string()

def short_string()

def to_flyte_idl()

class TaskExecutionGetDataResponse(
    inputs,
    outputs,
    full_inputs,
    full_outputs,
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class WorkflowExecutionGetDataResponse(
    inputs,
    outputs,
    full_inputs,
    full_outputs,
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()