flytekit.remote.entities.FlyteWorkflowNode#

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

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

Methods

Parameters
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, converted_sub_workflows)[source]#
Parameters

  • base_model (flytekit.models.core.workflow.WorkflowNode) –

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

  • node_launch_plans (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[flytekit.remote.entities.FlyteWorkflowNode, Dict[flytekit.models.core.identifier.Identifier, flytekit.remote.entities.FlyteWorkflow]]

serialize_to_string()#
Return type

str

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