tfx.orchestration.experimental.core.task.ExecNodeTask

Task to instruct execution of a node in the pipeline.

Inherits From: Task

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

@classmethod
task_type_id() -> str

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.