tfx.orchestration.portable.tfx_runner.TfxRunner

Base runner class for TFX.

This is the base class for every TFX runner.

Methods

run

View source

@abc.abstractmethod
run(
    pipeline: pipeline_pb2.Pipeline
) -> Optional[Any]

Runs a TFX pipeline on a specific platform.

Args
pipeline	a pipeline_pb2.Pipeline message representing a pipeline definition.

Returns
Optional platform-specific object.