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)[source]#
- 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[FlyteNode | None, Dict[Identifier, FlyteWorkflow]]
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