code: def serve():
      server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
      ml_pb2_grpc.add_MLServiceServicer_to_server(
          MLServiceServicer(), server
      )
      server.add_insecure_port("[::]:50052")
      logger.info("staring rpc server on [::]:50052")
      server.start()
      server.wait_for_termination()
  
imports: import json
  import pickle
  import traceback
  from concurrent import futures
  import grpc
  from mindsdb.microservices_grpc.ml import ml_pb2_grpc
  from mindsdb.microservices_grpc.ml import ml_pb2, common_pb2
  from mindsdb.interfaces.storage.model_fs import ModelStorage, HandlerStorage
  from mindsdb.integrations.libs.response import RESPONSE_TYPE
  from mindsdb.interfaces.database.integrations import integration_controller
  from mindsdb.integrations.libs.handler_helpers import get_handler
  from mindsdb.utilities.context import context
  from mindsdb.utilities import log
label_desc: Use image node_id 1 for calling a global function with example usage: serve() without return types