Execution objects#

class flytekit.remote.executions.FlyteWorkflowExecution(*args, **kwargs)#

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

property error: ExecutionError#

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

property is_done: bool#

Whether or not the execution is complete.

property node_executions: Dict[str, FlyteNodeExecution]#

Get a dictionary of node executions that are a part of this workflow execution.

class flytekit.remote.executions.FlyteTaskExecution(*args, **kwargs)#

A class encapsulating a task execution being run on a Union remote backend.

property error: ExecutionError | None#

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

property is_done: bool#

Whether or not the execution is complete.

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

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

property error: ExecutionError#

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

property interface: flytekit.remote.interface.TypedInterface#

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

property is_done: bool#

Whether or not the execution is complete.

property subworkflow_node_executions: Dict[str, FlyteNodeExecution]#

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.