code: def test_start_pipeline_failure_to_initiate(self, mock_start):
      mock_start.side_effect = status_lib.StatusNotOkError(
          code=status_lib.Code.ALREADY_EXISTS, message="already exists"
      )
      request = service_pb2.StartPipelineRequest(
          pipeline=pipeline_pb2.Pipeline()
      )
      with self.assertRaisesRegex(
          grpc.RpcError, "already exists"
      ) as exception_context:
          self._stub.StartPipeline(request)
      self.assertIs(
          grpc.StatusCode.ALREADY_EXISTS,
          exception_context.exception.code(),
      )
      mock_start.assert_called_once()
  
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 5 for calling the KubernetesOrchestratorServiceTest obj's underlying member method code with example usage: obj.test_start_pipeline_failure_to_initiate(mock_start) without return types