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

: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.remote.identifier.Identifier, flytekit.models.core.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.