class_docstr: A service interface for pipeline orchestration.
docstr: Echoes the input user message to test the server.
  
  Args:
    request: A service_pb2.Echo object containing the message user wants to
      echo.
    servicer_context: A grpc.ServicerContext for use during service of the
      RPC.
  
  Returns:
    A service_pb2.Echo object containing the message to echo.
code: def Echo(
      self,
      request: service_pb2.EchoRequest,
      servicer_context: grpc.ServicerContext,
  ):
      """Echoes the input user message to test the server.
  
      Args:
        request: A service_pb2.Echo object containing the message user wants to
          echo.
        servicer_context: A grpc.ServicerContext for use during service of the
          RPC.
  
      Returns:
        A service_pb2.Echo object containing the message to echo.
      """
      return service_pb2.EchoResponse(msg=request.msg)
  
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 2 for calling the KubernetesOrchestratorServicer obj's underlying member method code with example usage: obj.Echo(request, servicer_context) and returns: service_pb2