diff --git a/backend/btrixcloud/pages.py b/backend/btrixcloud/pages.py
index ec047f73b..4d50b822a 100644
--- a/backend/btrixcloud/pages.py
+++ b/backend/btrixcloud/pages.py
@@ -371,7 +371,7 @@ async def re_add_crawl_pages(self, crawl_id: str, oid: UUID):
 
     async def re_add_all_crawl_pages(self, oid: UUID):
         """Re-add pages for all crawls in org"""
-        crawl_ids = await crawls_mdb.distinct(
+        crawl_ids = await crawls.distinct(
             "_id", {"type": "crawl", "finished": {"$ne": None}}
         )
         for crawl_id in crawl_ids: