code: def run(self, **kwargs):
      host = kwargs.get("host", "127.0.0.1")
      port = kwargs.get("port", 50051)
      addr = f"{host}:{port}"
      server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
      db_pb2_grpc.add_DBServiceServicer_to_server(
          DBServiceServicer(), server
      )
      server.add_insecure_port(addr)
      # logger.info("staring rpc server on [::]:50051")
      server.start()
      server.wait_for_termination()
  
imports: import json
  import pickle
  import traceback
  from concurrent import futures
  import grpc
  from mindsdb.microservices_grpc.db import db_pb2_grpc
  from mindsdb.microservices_grpc.db import db_pb2, common_pb2
  from mindsdb.interfaces.file.file_controller import FileController
  from mindsdb.integrations.libs.handler_helpers import get_handler
  from mindsdb.api.executor.data_types.response_type import RESPONSE_TYPE
  from mindsdb.utilities.context import context
  from mindsdb.utilities import log
label_desc: Use image node_id 10 for calling the DBServiceServicer obj's underlying member method code with example usage: obj.run() without return types