code: def extract_mlmd_connection(
      connection_config: any_pb2.Any,
  ) -> metadata_pb2.MLMDConnectionConfig:
      result = metadata_pb2.MLMDConnectionConfig()
      for (
          name
      ) in metadata_pb2.MLMDConnectionConfig.DESCRIPTOR.fields_by_name:
          if connection_config.Unpack(getattr(result, name)):
              break
      return result
  
file_path: tfx/tfx/orchestration/local/runner_utils.py
imports: from typing import Optional
  from absl import logging
  from tfx.proto.orchestration import local_deployment_config_pb2
  from tfx.proto.orchestration import metadata_pb2
  from tfx.proto.orchestration import pipeline_pb2
  from google.protobuf import any_pb2
  from google.protobuf import message
label_desc: Use image node_id 5 for calling a global function with example usage: extract_mlmd_connection(connection_config) and returns: result