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 = None,
)

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] = None,
    outputs: typing.Optional[LiteralMapBlob] = None,
    abort_metadata: typing.Optional[AbortMetadata] = None,
    created_at: typing.Optional[datetime.datetime] = None,
    updated_at: typing.Optional[datetime.datetime] = None,
)

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] = None,
    parent_node_execution: Optional[_identifier.NodeExecutionIdentifier] = None,
    reference_execution: Optional[_identifier.WorkflowExecutionIdentifier] = None,
    system_metadata: Optional[SystemMetadata] = None,
)

def from_flyte_idl(
    pb2_object,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

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

def from_flyte_idl(
    p,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class LiteralMapBlob(
    values = None,
    uri = None,
)

def from_flyte_idl(
    pb,
)

def serialize_to_string()

def short_string()

def to_flyte_idl()

class NodeExecutionGetDataResponse(
    *args,
    dynamic_workflow: typing.Optional[DynamicWorkflowNodeMetadata] = None,
    **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()