flytekit.remote.nodes.FlyteNodeExecution

class flytekit.remote.nodes.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.admin.node_execution.NodeExecution

classmethod promote_from_model(base_model)[source]
Parameters

base_model (flytekit.models.admin.node_execution.NodeExecution) –

Return type

flytekit.remote.nodes.FlyteNodeExecution

short_string()
Return type

Text

sync()[source]

Syncs the state of the underlying execution artifact with the state observed by the platform.

to_flyte_idl()
Return type

flyteidl.admin.node_execution_pb2.NodeExecution

verbose_string()
Return type

Text

wait_for_completion(timeout=None, poll_interval=None)
Parameters
  • timeout (datetime.timedelta) – Amount of time to wait until the execution has completed before timing out. If not set or set to None, this method will wait for infinite.

  • poll_interval (datetime.timedelta) – Duration to wait between polling for a completion update.

Return type

None

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

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

interface

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

is_complete

Whether or not the execution is complete.

is_empty
metadata
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.

subworkflow_node_executions
task_executions