flytekit.remote.executions.FlyteWorkflowExecution

class flytekit.remote.executions.FlyteWorkflowExecution(*args, **kwargs)[source]

A class encapsulating a workflow execution being run on a Flyte remote backend.

Methods

classmethod from_flyte_idl(pb)
Parameters:

pb (flyteidl.admin.execution_pb2.Execution)

Return type:

Execution

classmethod promote_from_model(base_model)[source]
Parameters:

base_model (Execution)

Return type:

FlyteWorkflowExecution

serialize_to_string()
Return type:

str

short_string()
Return type:

Text

to_flyte_idl()
Return type:

flyteidl.admin.execution_pb2.Execution

verbose_string()
Return type:

Text

Attributes

closure

ExecutionClosure

Type:

rtype

error

If execution is in progress, raise an exception. Otherwise, return None if no error was present upon reaching completion.

flyte_workflow
id

flytekit.models.core.identifier.WorkflowExecutionIdentifier

Type:

rtype

inputs
is_done

Whether or not the execution is complete.

is_empty
node_executions

Get a dictionary of node executions that are a part of this workflow execution.

outputs

Returns the outputs LiteralsResolver to the execution :raises: FlyteAssertion error if execution is in progress or execution ended in error.

Type:

return

spec

ExecutionSpec

Type:

rtype