code: def _create_mlmd_connection():
      """Creates connection for MLMD."""
      connection_config = metadata.mysql_metadata_connection_config(
          host=_MYSQL_HOST_FLAG.value,
          port=_MYSQL_PORT_FLAG.value,
          username=_MYSQL_USERNAME_FLAG.value,
          database=_MYSQL_DATABASE_FLAG.value,
          password=_MYSQL_PASSWORD_FLAG.value,
      )
      return metadata.Metadata(connection_config=connection_config)
  
imports: from concurrent import futures
  import contextlib
  import time
  from absl import app
  from absl import flags
  from absl import logging
  import grpc
  from tfx.orchestration import metadata
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator import kubernetes_task_scheduler
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service import kubernetes_orchestrator_service
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2_grpc
  from tfx.orchestration.experimental.core import event_observer
  from tfx.orchestration.experimental.core import pipeline_ops
  from tfx.orchestration.experimental.core import pipeline_state
  from tfx.orchestration.experimental.core import service_jobs
  from tfx.orchestration.experimental.core import task_manager
  from tfx.orchestration.experimental.core import task_queue
  from tfx.orchestration.experimental.core import task_scheduler
label_desc: Use image node_id 2 for calling a global function with example usage: _create_mlmd_connection() and returns: metadata