diff --git a/aredis_om/model/model.py b/aredis_om/model/model.py
index 92bb6f9a..b4f82882 100644
--- a/aredis_om/model/model.py
+++ b/aredis_om/model/model.py
@@ -754,7 +754,7 @@ async def first(self):
             raise NotFoundError()
         return results[0]
 
-    async def all(self, batch_size=10):
+    async def all(self, batch_size=DEFAULT_PAGE_SIZE):
         if batch_size != self.page_size:
             query = self.copy(page_size=batch_size, limit=batch_size)
             return await query.execute()