|View source on GitHub|
Tfx runner on Beam.
Initializes BeamDagRunner as a TFX orchestrator.
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.
Deploys given logical pipeline on Beam.
tfx_pipeline: Logical pipeline containing pipeline args and components.