|View source on GitHub|
Tfx runner on Beam.
tfx.orchestration.beam.legacy.beam_dag_runner.BeamDagRunner( beam_orchestrator_args: Optional[List[Text]] = None, config: Optional[
tfx.orchestration.config.pipeline_config.PipelineConfig] = None )
||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.|
||Optional pipeline config for customizing the launching of each component. Defaults to pipeline config that supports InProcessComponentLauncher and DockerComponentLauncher.|
tfx.orchestration.pipeline.Pipeline) -> None
Deploys given logical pipeline on Beam.
||Logical pipeline containing pipeline args and components.|