![]() |
Base runner class for TFX.
This is the base class for every TFX runner.
Methods
run
@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. |