flytekit.remote.entities.FlyteNode

class flytekit.remote.entities.FlyteNode(id, upstream_nodes, bindings, metadata, task_node=None, workflow_node=None, branch_node=None, gate_node=None, array_node=None)[source]

A class encapsulating a remote Flyte node.

Methods

Parameters:

  • task_node (Optional[FlyteTaskNode])

  • workflow_node (Optional[FlyteWorkflowNode])

  • branch_node (Optional[FlyteBranchNode])

  • gate_node (Optional[FlyteGateNode])

  • array_node (Optional[FlyteArrayNode])

classmethod from_flyte_idl(pb2_object)
Parameters:

pb2_object (flyteidl.core.workflow_pb2.Node)

Return type:

Node

classmethod promote_from_model(model, sub_workflows, node_launch_plans, tasks, converted_sub_workflows)[source]
Parameters:

  • model (Node)

  • sub_workflows (Dict[Identifier, WorkflowTemplate] | None)

  • node_launch_plans (Dict[Identifier, LaunchPlanSpec] | None)

  • tasks (Dict[Identifier, FlyteTask])

  • converted_sub_workflows (Dict[Identifier, FlyteWorkflow])

Return type:

Tuple[FlyteNode | None, Dict[Identifier, FlyteWorkflow]]

serialize_to_string()
Return type:

str

short_string()
Return type:

Text

to_flyte_idl()
Return type:

flyteidl.core.workflow_pb2.Node

verbose_string()
Return type:

Text

Attributes

array_node
branch_node

[Optional] Information about the branch node to evaluate in this node.

Return type:

BranchNode

flyte_entity
gate_node
id

A workflow-level unique identifier that identifies this node in the workflow. “inputs” and “outputs” are reserved node ids that cannot be used by other nodes.

Return type:

Text

inputs

Specifies how to bind the underlying interface’s inputs. All required inputs specified in the underlying interface must be fulfilled.

Return type:

list[flytekit.models.literals.Binding]

is_empty
metadata

Extra metadata about the node.

Return type:

NodeMetadata

output_aliases

[Optional] A node can define aliases for a subset of its outputs. This is particularly useful if different nodes need to conform to the same interface (e.g. all branches in a branch node). Downstream nodes must refer to this node’s outputs using the alias if one is specified.

Return type:

list[Alias]

target

T

Type:

rtype

task_node
upstream_node_ids
upstream_nodes
workflow_node

[Optional] Information about the Workflow to execute in this mode.

Return type:

WorkflowNode