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