|View source on GitHub|
Legacy TFX BeamDagRunner.
This runner is not based on the TFX IR and is kept for compatibility. It will be deprecated in a future release.
run( pipeline: Union[pipeline_pb2.Pipeline,
tfx.orchestration.pipeline.Pipeline] ) -> None
Deploys given logical pipeline on Beam.
||Logical pipeline in IR format.|