def create_and_start_server(port, servicer):
  """Create a server for pushing examples and starts it.


  Args:
    port: Port for the gRPC server to listen on.
    servicer: A PreprocessingServicer object.

  Returns:
    A grpc.Server object.
  """
  server = grpc.server(logging_pool.pool(max_workers=25))
  preprocessing_pb2_grpc.add_PreprocessingServicer_to_server(servicer, server)
  address = "[::]:%d" % port
  tf.logging.info("Create preprocessing server at %s", address)
  server.add_insecure_port(address)
  server.start()
  return server
Create a server for pushing examples and starts it.


  Args:
    port: Port for the gRPC server to listen on.
    servicer: A PreprocessingServicer object.

  Returns:
    A grpc.Server object.
  
language/realm/preprocessing.py