flytekit.remote.entities.FlyteWorkflowNode

class flytekit.remote.entities.FlyteWorkflowNode(flyte_workflow=None, flyte_launch_plan=None)

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

Methods

Parameters:

• flyte_workflow (FlyteWorkflow)

• flyte_launch_plan (FlyteLaunchPlan)

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)

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