When loading unprocessed records, process those with the most downloa…

…ds first.
coherent-oss · Jan 13, 2025 · 81b1b5a · 81b1b5a
1 parent 63954d8
commit 81b1b5a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pypi.py b/pypi.py
@@ -193,8 +193,9 @@ def from_row(cls, row):
 
     @classmethod
     def unprocessed(cls):
-        query = {"updated": {"$exists": False}}
-        return map(cls, map(operator.itemgetter('id'), store().find(query)))
+        query = dict(updated={"$exists": False})
+        sort = dict(downloads=-1)
+        return map(cls, map(operator.itemgetter('id'), store().find(query, sort=sort)))
 
     def refresh(self):
         vars(self).update(self.from_wheel())