Join the SIG TFX-Addons community and help make TFX even better!

tfx.orchestration.experimental.core.task.ExecNodeTask

Task to instruct execution of a node in the pipeline.

Inherits From: Task

node_uid Uid of the node to be executed.
execution MLMD execution associated with current node.
contexts List of contexts associated with the execution.
exec_properties Execution properties of the execution.
input_artifacts Input artifacts dict.
output_artifacts Output artifacts dict.
executor_output_uri URI for the executor output.
stateful_working_dir Working directory for the node execution.
pipeline The pipeline IR proto containing the node to be executed.
is_cancelled Indicates whether this is a cancelled execution. The task scheduler is expected to gracefully exit after doing any necessary cleanup.
task_id Returns a unique identifier for this task.

The concrete implementation must ensure that the returned task id is unique across all task types.

Methods

task_type_id

View source

Returns task type id.

__eq__

Method generated by attrs for class ExecNodeTask.

__ge__

Method generated by attrs for class ExecNodeTask.

__gt__

Method generated by attrs for class ExecNodeTask.

__le__

Method generated by attrs for class ExecNodeTask.

__lt__

Method generated by attrs for class ExecNodeTask.

__ne__

Method generated by attrs for class ExecNodeTask.