Fixing some test errors

Author: petyaslavova

tests/test_asyncio/test_commands.py

@@ -3627,9 +3627,7 @@ async def test_xreadgroup_with_claim_min_idle_time_multiple_streams_same_slots(
         await r.xgroup_create(stream_2, group, 0)
 
         # read all the messages - this will save the msgs in PEL
-        await r.xreadgroup(
-            group, consumer_1, streams={stream_1: ">", stream_2: ">"}
-        )
+        await r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # wait for 100ms - so that the messages would have been in the PEL for long enough
         await asyncio.sleep(0.1)
@@ -3690,6 +3688,7 @@ async def test_xreadgroup_with_claim_min_idle_time_multiple_streams_same_slots(
         await r.xadd(stream_2, {"key_m6": "val_m6"})
 
         # read all the messages - this will save the msgs in PEL
+        r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # add 2 more messages
         m7 = await r.xadd(stream_1, {"key_m7": "val_m7"})
@@ -3745,9 +3744,7 @@ async def test_xreadgroup_with_claim_min_idle_time_multiple_streams(self, r):
         await r.xgroup_create(stream_2, group, 0)
 
         # read all the messages - this will save the msgs in PEL
-        await r.xreadgroup(
-            group, consumer_1, streams={stream_1: ">", stream_2: ">"}
-        )
+        await r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # wait for 100ms - so that the messages would have been in the PEL for long enough
         await asyncio.sleep(0.1)
@@ -3808,9 +3805,7 @@ async def test_xreadgroup_with_claim_min_idle_time_multiple_streams(self, r):
         await r.xadd(stream_2, {"key_m6": "val_m6"})
 
         # read all the messages - this will save the msgs in PEL
-        res = await r.xreadgroup(
-            group, consumer_1, streams={stream_1: ">", stream_2: ">"}
-        )
+        await r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # add 2 more messages
         m7 = await r.xadd(stream_1, {"key_m7": "val_m7"})

tests/test_commands.py

@@ -5300,7 +5300,7 @@ def test_xreadgroup_with_claim_min_idle_time_multiple_streams_same_slots(self, r
         r.xadd(stream_2, {"key_m6": "val_m6"})
 
         # read all the messages - this will save the msgs in PEL
-        res = r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
+        r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # add 2 more messages
         m7 = r.xadd(stream_1, {"key_m7": "val_m7"})
@@ -5399,7 +5399,7 @@ def test_xreadgroup_with_claim_min_idle_time_multiple_streams(self, r):
         r.xadd(stream_2, {"key_m6": "val_m6"})
 
         # read all the messages - this will save the msgs in PEL
-        res = r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
+        r.xreadgroup(group, consumer_1, streams={stream_1: ">", stream_2: ">"})
 
         # add 2 more messages
         m7 = r.xadd(stream_1, {"key_m7": "val_m7"})