![]() |
Base runner class for TFX.
tfx.orchestration.tfx_runner.TfxRunner(
config: Optional[tfx.orchestration.config.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
@abc.abstractmethod
run( pipeline ) -> Optional[Any]
Runs logical TFX pipeline on specific platform.
Args | |
---|---|
pipeline
|
logical TFX pipeline definition. |
Returns | |
---|---|
Platform-specific object. |