tfx.orchestration.tfx_runner.TfxRunner

View source on GitHub

Base runner class for TFX.

tfx.orchestration.tfx_runner.TfxRunner(
    config: Optional[pipeline_config.PipelineConfig] = None
)

This is the base class for every TFX runner.

Args
config	Optional pipeline config for customizing the launching of each component.

Methods

run

View source

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

Runs logical TFX pipeline on specific platform.

Args
pipeline	logical TFX pipeline definition.

Returns
Platform-specific object.