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: Union[pipeline_pb2.Pipeline, tfx.orchestration.pipeline.Pipeline]
) -> Optional[Any]

Runs a TFX pipeline on a specific platform.

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

Returns
Optional platform-specific object.