code: def _start_grpc_server(
      servicer: kubernetes_orchestrator_service.KubernetesOrchestratorServicer,
  ) -> grpc.Server:
      """Starts GRPC server."""
      server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
      service_pb2_grpc.add_KubernetesOrchestratorServicer_to_server(
          servicer, server
      )
      server_creds = grpc.local_server_credentials()
      server.add_secure_port(
          f"[::]:{_SERVER_PORT_FLAG.value}", server_creds
      )
      server.start()
      return server
  
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 1 for calling a global function with example usage: _start_grpc_server(servicer) and returns: server