race-fix7

resolvers/load.py

@@ -6,6 +6,9 @@ from services.auth import login_required
 from services.schema import query
 from .chats import create_chat
 from .unread import get_unread_counter
+import asyncio
+
+lock = asyncio.Lock()
 
 
 # NOTE: not an API handler
@@ -55,15 +58,8 @@ async def load_chats(_, info, limit: int = 50, offset: int = 0):
         cids.append(r["chat"]["id"])
 
     for cid in cids:
-        # Start a pipeline
-        pipeline = await redis.pipeline()
-        # Add the GET command to the pipeline
-        await pipeline.get(f"chats/{cid}")
-        # Execute the pipeline
-        result = await pipeline.execute()
-        # Get the result of the GET command
-        c = result[0]
-        print(f"got chat {c}")
+        async with lock:
+            c = await redis.execute("GET", f"chats/{cid}")
             if c:
                 c = json.loads(c)
                 c["messages"] = await load_messages(cid, 5, 0)