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 (flytekit.models.execution.Execution) –

Return type

flytekit.remote.executions.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