tfx.orchestration.portable.system_node_handler.SystemNodeHandler

SystemNodeHandler is the base class of all system nodes' handler.

Methods

run

View source

@abc.abstractmethod
run(
    mlmd_connection: tfx.orchestration.metadata.Metadata,
    pipeline_node: pipeline_pb2.PipelineNode,
    pipeline_info: pipeline_pb2.PipelineInfo,
    pipeline_runtime_spec: pipeline_pb2.PipelineRuntimeSpec
) -> metadata_store_pb2.Execution

Runs the system node and return the Execution.

Args
mlmd_connection	ML metadata connection.
pipeline_node	The specification of the node that this launcher lauches.
pipeline_info	The information of the pipeline that this node runs in.
pipeline_runtime_spec	The runtime information of the pipeline that this node runs in.

Returns
The execution of the run.