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 (WorkflowNode)

  • sub_workflows (Dict[Identifier, WorkflowTemplate])

  • node_launch_plans (Dict[Identifier, LaunchPlanSpec])

  • tasks (Dict[Identifier, FlyteTask])

  • converted_sub_workflows (Dict[Identifier, FlyteWorkflow])

Return type:

Tuple[FlyteWorkflowNode, Dict[Identifier, 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