class_docstr: A service interface for pipeline orchestration.
code: def __init__(self, mlmd_handle: metadata.Metadata):
      self._mlmd_handle = mlmd_handle
  
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 1 to create a new KubernetesOrchestratorServicer object from inherited base classes: service_pb2_grpc with example: obj = KubernetesOrchestratorServicer(mlmd_handle)