class_docstr: Tfx runner on Beam.
class_docstr_tok: ["Tfx","runner","on","Beam","."]
code: def _connection_config_from_deployment_config(
      self, deployment_config: Any
  ) -> Any:
      return getattr(
          deployment_config.metadata_connection_config,
          deployment_config.metadata_connection_config.WhichOneof(
              "connection_config"
          ),
      )
  
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 7 for calling the BeamDagRunner obj's underlying member method code with example usage: obj._connection_config_from_deployment_config(deployment_config) and returns: getattr