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.

Parameters
  • id (flytekit.models.core.identifier.WorkflowExecutionIdentifier) –

  • spec (ExecutionSpec) –

  • closure (ExecutionClosure) –

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

FlyteWorkflowExecution

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