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
Return type

Tuple[Optional[flytekit.remote.entities.FlyteNode], Dict[flytekit.models.core.identifier.Identifier, flytekit.remote.entities.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