code: def setUpClass(cls):
      super().setUpClass()
      port = portpicker.pick_unused_port()
  
      server_pool = logging_pool.pool(max_workers=25)
      cls._server = grpc.server(server_pool)
      cls._server.add_secure_port(
          f"[::]:{port}".format(port), grpc.local_server_credentials()
      )
      servicer = kubernetes_orchestrator_service.KubernetesOrchestratorServicer(
          mock.Mock()
      )
      service_pb2_grpc.add_KubernetesOrchestratorServicer_to_server(
          servicer, cls._server
      )
      cls._server.start()
      cls._channel = grpc.secure_channel(
          f"localhost:{port}", grpc.local_channel_credentials()
      )
      cls._stub = service_pb2_grpc.KubernetesOrchestratorStub(
          cls._channel
      )
  
file_path: tfx/tfx/orchestration/experimental/centralized_kubernetes_orchestrator/service/kubernetes_orchestrator_service_test.py
imports: from unittest import mock
  import grpc
  from grpc.framework.foundation import logging_pool
  import portpicker
  import tensorflow
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service import kubernetes_orchestrator_service
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2
  from tfx.orchestration.experimental.centralized_kubernetes_orchestrator.service.proto import service_pb2_grpc
  from tfx.orchestration.experimental.core import pipeline_ops
  from tfx.orchestration.experimental.core import task
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.utils import status
label_desc: Use image node_id 1 for calling the KubernetesOrchestratorServiceTest obj's underlying member method code with example usage: obj.setUpClass(cls) without return types