class_docstr: A service interface for pipeline orchestration.
code: def StartPipeline(
      self,
      request: service_pb2.StartPipelineRequest,
      context: grpc.ServicerContext,
  ) -> service_pb2.StartPipelineResponse:
      try:
          pipeline_ops.initiate_pipeline_start(
              self._mlmd_handle, request.pipeline
          )
      except status_lib.StatusNotOkError as e:
          context.set_code(_CANONICAL_TO_GRPC_CODES[e.code])
          context.set_details(e.message)
      return service_pb2.StartPipelineResponse()
  
file_path: tfx/tfx/orchestration/experimental/centralized_kubernetes_orchestrator/service/kubernetes_orchestrator_service.py
imports: from typing import Dict
  import grpc
  from tfx.orchestration import metadata
  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.utils import status
label_desc: Use image node_id 3 for calling the KubernetesOrchestratorServicer obj's underlying member method code with example usage: obj.StartPipeline(request, context) and returns: service_pb2