class_docstr: Implements of grpc pipeline service.
code: def Predict(self, request, context):
      path = request.path
      if path not in self._router_map:
          err_msg = "Unkown service path: %s, all paths is %s" % (
              path,
              list(self._router_map.keys()),
          )
          engine_log.error(err_msg)
          response = service_pb2.Response(code=-1, msg=err_msg)
      try:
          response = self._run_func(request)
      except Exception as e:  # pylint: disable=broad-except
          engine_log.error(traceback.format_exc())
          response = service_pb2.Response(code=-1, msg=str(e))
      engine_log.info(
          "gRPC method called: %s, response code: %s",
          path,
          response.code,
      )
      return response
  
imports: import typing
  import inspect
  import traceback
  from concurrent import futures
  from towhee.utils.thirdparty.grpc_utils import grpc
  from .None import service_pb2
  from .None import service_pb2_grpc
  from towhee.serve.io import JSON, TEXT, BYTES, NDARRAY
  from towhee.serve.api_service import RouterConfig
  from towhee.utils.log import engine_log
label_desc: Use image node_id 5 for calling the _PipelineImpl obj's underlying member method code with example usage: obj.Predict(request, context) and returns: response