def METHOD_NAME(self):
    # execute query on each one of the threads
    n_queries_to_execute = self.conn.execute_command("GRAPH.CONFIG", "GET", "THREAD_COUNT")[1]
    # set query memory limit to 1MB
    limit = 1024*1024
    self.conn.execute_command("GRAPH.CONFIG", "SET", "QUERY_MEM_CAPACITY", limit)
    self.stress_server([(MEM_HOG_QUERY, True)] * n_queries_to_execute)