race-fix6
This commit is contained in:
parent
00d2066564
commit
95bf812ae2
|
@ -58,7 +58,7 @@ async def load_chats(_, info, limit: int = 50, offset: int = 0):
|
||||||
# Start a pipeline
|
# Start a pipeline
|
||||||
pipeline = await redis.pipeline()
|
pipeline = await redis.pipeline()
|
||||||
# Add the GET command to the pipeline
|
# Add the GET command to the pipeline
|
||||||
pipeline.get(f"chats/{cid}")
|
await pipeline.get(f"chats/{cid}")
|
||||||
# Execute the pipeline
|
# Execute the pipeline
|
||||||
result = await pipeline.execute()
|
result = await pipeline.execute()
|
||||||
# Get the result of the GET command
|
# Get the result of the GET command
|
||||||
|
|
Loading…
Reference in New Issue
Block a user