diff --git a/aredis_om/model/model.py b/aredis_om/model/model.py
index 92bb6f9a..da8fcaf1 100644
--- a/aredis_om/model/model.py
+++ b/aredis_om/model/model.py
@@ -742,7 +742,7 @@ async def execute(self, exhaust_results=True):
             # current offset plus `page_size`, until we stop getting results back.
             query = query.copy(offset=query.offset + query.page_size)
             _results = await query.execute(exhaust_results=False)
-            if not _results:
+            if not _results or len(self._model_cache) >= query.limit:
                 break
             self._model_cache += _results
         return self._model_cache