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)[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]) –

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

branch_node#

[Optional] Information about the branch node to evaluate in this node. :rtype: 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. :rtype: Text

inputs#

Specifies how to bind the underlying interface’s inputs. All required inputs specified in the underlying interface must be fulfilled. :rtype: list[flytekit.models.literals.Binding]

is_empty#
metadata#

Extra metadata about the node. :rtype: 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. :rtype: list[Alias]

target#

T

Type

rtype

task_node#

[Optional] Information about the Task to execute in this node. :rtype: TaskNode

upstream_node_ids#
upstream_nodes#
workflow_node#

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