code: def send_query(self, query):
          
          message = riemann_client.riemann_pb2.Msg()
          message.query.string = query
          return self.transport.send(message)
docs: Sends a query to the Riemann server
  
          :returns: The response message from Riemann