flytekit.remote.nodes.FlyteNode#

class flytekit.remote.nodes.FlyteNode(id, upstream_nodes, bindings, metadata, flyte_task=None, flyte_workflow=None, flyte_launch_plan=None, flyte_branch_node=None)[source]#

A class encapsulating a remote Flyte node.

Methods

Parameters
  • flyte_task (Optional['FlyteTask']) –

  • flyte_workflow (Optional['FlyteWorkflow']) –

  • flyte_launch_plan (Optional['FlyteLaunchPlan']) –

  • flyte_branch_node (Optional['FlyteBranchNode']) –

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)[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 (Optional[Dict[flytekit.models.core.identifier.Identifier, flytekit.models.task.TaskTemplate]]) –

Return type

flytekit.remote.nodes.FlyteNode

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#
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]

outputs#
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