From 2908e62229ec1722401a2d8e023b9f9cc45af232 Mon Sep 17 00:00:00 2001 From: Andrew Carbonetto Date: Sat, 29 Jun 2024 19:12:38 -0700 Subject: [PATCH] #1715: fix flakey test in xpending (#1717) #1715: fix flacky test in xpending Signed-off-by: Andrew Carbonetto --- java/integTest/src/test/java/glide/SharedCommandTests.java | 2 ++ python/python/tests/test_async_client.py | 2 ++ 2 files changed, 4 insertions(+) diff --git a/java/integTest/src/test/java/glide/SharedCommandTests.java b/java/integTest/src/test/java/glide/SharedCommandTests.java index 8d651fb393..78db33e715 100644 --- 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 index 46b7b55428..eb7fd7a912 100644 --- 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 )