tfx.orchestration.experimental.core.task.ExecNodeTask

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
)

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

View source

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