|View source on GitHub|
Tfx runner on Beam.
__init__( beam_orchestrator_args=None, config=None )
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.
config: Optional pipeline config for customizing the launching of each component.
Deploys given logical pipeline on Beam.
tfx_pipeline: Logical pipeline containing pipeline args and components.