flytekit.remote.component_nodes.FlyteWorkflowNode

class flytekit.remote.component_nodes.FlyteWorkflowNode(flyte_workflow=None, flyte_launch_plan=None)[source]

A class encapsulating a workflow that a Flyte node needs to execute.

Refers to a the workflow the node is to execute. One of the references must be supplied.

Parameters
  • launchplan_ref (flytekit.models.core.identifier.Identifier) – [Optional] A globally unique identifier for the launch plan. Should map to Admin.

  • sub_workflow_ref (flytekit.models.core.identifier.Identifier) – [Optional] Reference to a subworkflow, that should be defined with the compiler context.

  • flyte_workflow (flytekit.remote.workflow.FlyteWorkflow) –

  • flyte_launch_plan (flytekit.remote.launch_plan.FlyteLaunchPlan) –

Methods

classmethod from_flyte_idl(pb2_object)
Parameters

pb2_object (flyteidl.core.workflow_pb2.WorkflowNode) –

Return type

WorkflowNode

classmethod promote_from_model(base_model, sub_workflows, node_launch_plans, tasks)[source]
Parameters
  • base_model (flytekit.models.core.workflow.WorkflowNode) –

  • sub_workflows (Dict[flytekit.remote.identifier.Identifier, flytekit.models.core.workflow.WorkflowTemplate]) –

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

  • tasks (Dict[flytekit.remote.identifier.Identifier, flytekit.models.core.task.TaskTemplate]) –

Return type

flytekit.remote.component_nodes.FlyteWorkflowNode

short_string()
Return type

Text

to_flyte_idl()
Return type

flyteidl.core.workflow_pb2.WorkflowNode

verbose_string()
Return type

Text

Attributes

flyte_launch_plan
flyte_workflow
is_empty
launchplan_ref

A globally unique identifier for the launch plan, which should map to Admin.

reference

flytekit.models.core.identifier.Identifier

Type

rtype

sub_workflow_ref