race-fix9
This commit is contained in:
@@ -59,6 +59,7 @@ async def load_chats(_, info, limit: int = 50, offset: int = 0):
|
||||
for cid in cids:
|
||||
async with lock:
|
||||
c = await redis.execute("GET", f"chats/{cid}")
|
||||
print(f"GET result for chat {cid}: {c}") # Add this line
|
||||
if c:
|
||||
c = json.loads(c)
|
||||
c["messages"] = await load_messages(cid, 5, 0)
|
||||
|
Reference in New Issue
Block a user