flytekit.models.execution

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

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def ClusterAssignment(
    cluster_pool,
):

def from_flyte_idl(
    p,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

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 Execution(
    id,
    spec,
    closure,
):

def from_flyte_idl(
    pb,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def ExecutionClosure(
    phase: int,
    started_at: datetime.datetime,
    duration: datetime.timedelta,
    error: typing.Optional[flytekit.models.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()

def verbose_string()

def ExecutionClusterLabel(
    value,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def 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()

def verbose_string()

def 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()

def verbose_string()

def LiteralMapBlob(
    values,
    uri,
):

def from_flyte_idl(
    pb,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def 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()

def verbose_string()

def NotificationList(
    notifications,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def SystemMetadata(
    execution_cluster: str,
):

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

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def TaskExecutionGetDataResponse(
    inputs,
    outputs,
    full_inputs,
    full_outputs,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()

def WorkflowExecutionGetDataResponse(
    inputs,
    outputs,
    full_inputs,
    full_outputs,
):

def from_flyte_idl(
    pb2_object,
):

def serialize_to_string()

def short_string()

def to_flyte_idl()

def verbose_string()