![]() |
Task to instruct execution of a node in the pipeline.
Inherits From: Task
, HasNodeUid
tfx.orchestration.experimental.core.task.ExecNodeTask(
node_uid, execution, contexts, exec_properties, input_artifacts,
output_artifacts, executor_output_uri, stateful_working_dir, pipeline,
is_cancelled=attr_dict['is_cancelled'].default
)
Attributes | |
---|---|
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. |
node_uid
|
Returns the unique identifier of the node. |
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
@classmethod
task_type_id() -> Text
Returns task type id.
__eq__
__eq__(
other
)
Method generated by attrs for class ExecNodeTask.
__ge__
__ge__(
other
)
Method generated by attrs for class ExecNodeTask.
__gt__
__gt__(
other
)
Method generated by attrs for class ExecNodeTask.
__le__
__le__(
other
)
Method generated by attrs for class ExecNodeTask.
__lt__
__lt__(
other
)
Method generated by attrs for class ExecNodeTask.
__ne__
__ne__(
other
)
Method generated by attrs for class ExecNodeTask.