class_docstr: Tfx runner on Beam.
class_docstr_tok: ["Tfx","runner","on","Beam","."]
docstr: Initializes BeamDagRunner as a TFX orchestrator.
  
  Create the legacy BeamDagRunner object if any of the legacy
  `beam_orchestrator_args` or `config` arguments are passed. A migration
  guide will be provided in a future TFX version for users of these arguments.
  
  Args:
    beam_orchestrator_args: Deprecated 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. If
      this option is used, the legacy non-IR-based BeamDagRunner will be
      constructed.
    config: Deprecated optional pipeline config for customizing the launching
      of each component. Defaults to pipeline config that supports
      InProcessComponentLauncher and DockerComponentLauncher. If this option
      is used, the legacy non-IR-based BeamDagRunner will be constructed.
  
  Returns:
    Legacy or IR-based BeamDagRunner object.
docstr_tok: ["Initializes","BeamDagRunner","as","a","TFX","orchestrator",".","Create","the","legacy","BeamDagRunner","object","if","any","of","the","legacy","`","beam_orchestrator_args","`","or","`","config","`","arguments","are","passed",".","A","migration","guide","will","be","provided","in","a","future","TFX","version","for","users","of","these","arguments",".","Args",":","beam_orchestrator_args",":","Deprecated","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",".","If","this","option","is","used",",","the","legacy","non-IR-based","BeamDagRunner","will","be","constructed",".","config",":","Deprecated","optional","pipeline","config","for","customizing","the","launching","of","each","component",".","Defaults","to","pipeline","config","that","supports","InProcessComponentLauncher","and","DockerComponentLauncher",".","If","this","option","is","used",",","the","legacy","non-IR-based","BeamDagRunner","will","be","constructed",".","Returns",":","Legacy","or","IR-based","BeamDagRunner","object","."]
code: def __new__(
      cls,
      beam_orchestrator_args: Optional[List[str]] = None,
      config: Optional[pipeline_config.PipelineConfig] = None,
  ):
      """Initializes BeamDagRunner as a TFX orchestrator.
  
      Create the legacy BeamDagRunner object if any of the legacy
      `beam_orchestrator_args` or `config` arguments are passed. A migration
      guide will be provided in a future TFX version for users of these arguments.
  
      Args:
        beam_orchestrator_args: Deprecated 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. If
          this option is used, the legacy non-IR-based BeamDagRunner will be
          constructed.
        config: Deprecated optional pipeline config for customizing the launching
          of each component. Defaults to pipeline config that supports
          InProcessComponentLauncher and DockerComponentLauncher. If this option
          is used, the legacy non-IR-based BeamDagRunner will be constructed.
  
      Returns:
        Legacy or IR-based BeamDagRunner object.
      """
      if beam_orchestrator_args or config:
          logging.info(
              "Using the legacy BeamDagRunner since `beam_orchestrator_args` or "
              "`config` argument was passed."
          )
          return legacy_beam_dag_runner.BeamDagRunner(
              beam_orchestrator_args=beam_orchestrator_args,
              config=config,
          )
      else:
          return super(BeamDagRunner, cls).__new__(cls)
  
imports: import datetime
  from typing import Any, Iterable, List, Optional
  from absl import logging
  import apache_beam
  from tfx.dsl.compiler import constants
  from tfx.orchestration import metadata
  from tfx.orchestration.beam.legacy import beam_dag_runner
  from tfx.orchestration.config import pipeline_config
  from tfx.orchestration.local import runner_utils
  from tfx.orchestration.portable import launcher
  from tfx.orchestration.portable import partial_run_utils
  from tfx.orchestration.portable import runtime_parameter_utils
  from tfx.orchestration.portable import tfx_runner
  from tfx.proto.orchestration import local_deployment_config_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import telemetry_utils
  from google.protobuf import any_pb2
  from google.protobuf import message
label_desc: Use image node_id 1 for calling the BeamDagRunner obj's underlying member method code with example usage: obj.__new__(cls, beam_orchestrator_args, config) and returns: legacy_beam_dag_runner, super