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
model (flytekit.models.core.workflow.Node) –
sub_workflows (Optional[Dict[flytekit.models.core.identifier.Identifier, flytekit.models.core.workflow.WorkflowTemplate]]) –
node_launch_plans (Optional[Dict[flytekit.models.core.identifier.Identifier, flytekit.models.launch_plan.LaunchPlanSpec]]) –
tasks (Dict[flytekit.models.core.identifier.Identifier, flytekit.remote.entities.FlyteTask]) –
converted_sub_workflows (Dict[flytekit.models.core.identifier.Identifier, flytekit.remote.entities.FlyteWorkflow]) –
- Return type
Tuple[Optional[flytekit.remote.entities.FlyteNode], Dict[flytekit.models.core.identifier.Identifier, flytekit.remote.entities.FlyteWorkflow]]
- 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