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.

Methods

classmethod from_flyte_idl(p)[source]#
Parameters:

p (NodeExecution)

Return type:

NodeExecution

classmethod promote_from_model(base_model)[source]#
Parameters:

base_model (NodeExecution)

Return type:

FlyteNodeExecution

serialize_to_string()[source]#
Return type:

str

short_string()[source]#
Return type:

Text

to_flyte_idl()[source]#
Return type:

NodeExecution

verbose_string()[source]#
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