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