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
- 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.