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=None, parameter_mapping=True)[source]

A class encapsulating a remote Flyte node.

Methods

Parameters
assign_id_and_return(id)[source]
Parameters

id (str) –

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.remote.identifier.Identifier, flytekit.models.core.workflow.WorkflowTemplate]]) –

  • node_launch_plans (Optional[Dict[flytekit.remote.identifier.Identifier, flytekit.models.admin.launch_plan.LaunchPlanSpec]]) –

  • tasks (Optional[Dict[flytekit.remote.identifier.Identifier, flytekit.models.core.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

with_overrides(*args, **kwargs)[source]

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