flytekit.remote.workflow_execution.FlyteWorkflowExecution

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

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

Parameters
  • id (Text) –

  • id

  • 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.admin.execution.Execution) –

Return type

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

id

flytekit.models.core.identifier.WorkflowExecutionIdentifier

Type

rtype

inputs

Returns the inputs to the execution in the standard python format as dictated by the type engine.

is_complete

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 to the execution in the standard python format as dictated by the type engine.

Raises

FlyteAssertion error if execution is in progress or execution ended in error.

spec

ExecutionSpec

Type

rtype