|View source on GitHub|
Tfx runner on Beam.
tfx.orchestration.beam.beam_dag_runner.BeamDagRunner( beam_orchestrator_args=None, config=None )
beam_orchestrator_args: beam args for the beam orchestrator. Note that this is different from the beam_pipeline_args within additional_pipeline_args, which is for beam pipelines in components.
config: Optional pipeline config for customizing the launching of each component.
run( tfx_pipeline )
Deploys given logical pipeline on Beam.
tfx_pipeline: Logical pipeline containing pipeline args and components.