flytekit.remote.entities.FlyteTaskNode#

class flytekit.remote.entities.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. 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.

  • flyteidl.core.workflow_pb2.TaskNodeOverrides

  • flyte_task (FlyteTask) –

Methods

classmethod from_flyte_idl(pb2_object)#
Parameters

pb2_object (flyteidl.core.workflow_pb2.TaskNode) –

Return type

TaskNode

classmethod promote_from_model(task)[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

task (flytekit.remote.entities.FlyteTask) –

Return type

flytekit.remote.entities.FlyteTaskNode

serialize_to_string()#
Return type

str

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.