#1715: fix flakey test in xpending (#1717)

#1715: fix flacky test in xpending Signed-off-by: Andrew Carbonetto <andrew.carbonetto@improving.com>
valkey-io · Jun 30, 2024 · 5ce7a32 · 5ce7a32
1 parent 583b2cd
commit 5ce7a32
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/java/integTest/src/test/java/glide/SharedCommandTests.java b/java/integTest/src/test/java/glide/SharedCommandTests.java
@@ -4375,6 +4375,8 @@ public void xpending(BaseClient client) {
         };
         assertDeepEquals(expectedResult, pending_results);
 
+        // ensure idle_time > 0
+        Thread.sleep(2000);
         Object[][] pending_results_extended =
                 client.xpending(key, groupName, InfRangeBound.MIN, InfRangeBound.MAX, 10L).get();
 

diff --git a/python/python/tests/test_async_client.py b/python/python/tests/test_async_client.py
@@ -5654,6 +5654,8 @@ async def test_xpending(self, redis_client: TGlideClient):
         result.remove(consumer_results)
         assert result == [5, stream_id1_0, stream_id1_4]
 
+        # to ensure an idle_time > 0
+        time.sleep(2)
         range_result = await redis_client.xpending_range(
             key, group_name, MinId(), MaxId(), 10
         )