Skip to content

Commit 4050c91

Browse files
committed
Fix async tests - await was missing
1 parent 4534691 commit 4050c91

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tests/test_asyncio/test_commands.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3688,7 +3688,7 @@ async def test_xreadgroup_with_claim_min_idle_time_multiple_streams_same_slots(
36883688
await r.xadd(stream_2, {"key_m6": "val_m6"})
36893689

36903690
# read all the messages - this will save the msgs in PEL
3691-
r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
3691+
await r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
36923692

36933693
# add 2 more messages
36943694
m7 = await r.xadd(stream_1, {"key_m7": "val_m7"})

0 commit comments

Comments
 (0)