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 as UNLIMITED
    limit = 0
    self.conn.execute_command("GRAPH.CONFIG", "SET", "QUERY_MEM_CAPACITY", limit) 
    self.stress_server([(MEM_HOG_QUERY, False)] * n_queries_to_execute)