Begin switching away from Redis

2022-10-21 11:14:51 +01:00
parent 8c06ec44cb
commit 73e2d24e0a
4 changed files with 24 additions and 49 deletions
--- a/sources/ingest.py
+++ b/sources/ingest.py
@@ -36,7 +36,7 @@ class Ingest(object):
        items = []
        # for source in SOURCES:
        # key = f"{KEYPREFIX}{source}"
-        chunk = await db.ar.spop(KEYNAME, CHUNK_SIZE)
+        chunk = await db.ar.zpop(KEYNAME, CHUNK_SIZE)
        if not chunk:
            return
        for item in chunk: