flytekit.remote.component_nodes.FlyteTaskNode#

class flytekit.remote.component_nodes.FlyteTaskNode(flyte_task)[source]#

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

Refers to the task that the Node is to execute. NB: This is currently a oneof in protobuf, but there’s only one option currently. This code should be updated

when more options are available.

Parameters
  • reference_id (flytekit.models.core.identifier.Identifier) – A globally unique identifier for the task.

  • flyte_task (flytekit.remote.task.FlyteTask) –

:param flyteidl.core.workflow_pb2.TaskNodeOverrides

Methods

classmethod from_flyte_idl(pb2_object)#
Parameters

pb2_object (flyteidl.core.workflow_pb2.TaskNode) –

Return type

TaskNode

classmethod promote_from_model(base_model, tasks)[source]#

Takes the idl wrapper for a TaskNode and returns the hydrated Flytekit object for it by fetching it with the FlyteTask control plane.

Parameters
  • base_model (flytekit.models.core.workflow.TaskNode) –

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

Return type

flytekit.remote.component_nodes.FlyteTaskNode

short_string()#
Return type

Text

to_flyte_idl()#
Return type

flyteidl.core.workflow_pb2.TaskNode

verbose_string()#
Return type

Text

Attributes

flyte_task#
is_empty#
overrides#
reference_id#

A globally unique identifier for the task.