flytekit.remote.executions.FlyteNodeExecution#

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

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

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

  • input_uri (Text) –

  • closure (NodeExecutionClosure) –

  • metadata (NodeExecutionMetaData) –

Methods

classmethod from_flyte_idl(p)#
Parameters

p (flyteidl.admin.node_execution_pb2.NodeExecution) –

Return type

flytekit.models.node_execution.NodeExecution

classmethod promote_from_model(base_model)[source]#
Parameters

base_model (flytekit.models.node_execution.NodeExecution) –

Return type

FlyteNodeExecution

serialize_to_string()#
Return type

str

short_string()#
Return type

Text

to_flyte_idl()#
Return type

flyteidl.admin.node_execution_pb2.NodeExecution

verbose_string()#
Return type

Text

Attributes

closure#

NodeExecutionClosure

Type

rtype

error#

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

executions#
id#

flytekit.models.core.identifier.NodeExecutionIdentifier

Type

rtype

input_uri#

Text

Type

rtype

inputs#
interface#

Return the interface of the task or subworkflow associated with this node execution.

is_done#

Whether or not the execution is complete.

is_empty#
metadata#
outputs#

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

Type

return

subworkflow_node_executions#

This returns underlying node executions in instances where the current node execution is a parent node. This happens when it’s either a static or dynamic subworkflow.

task_executions#
workflow_executions#