From 4072fed7c02ac6b55ebcbe908232641795d58496 Mon Sep 17 00:00:00 2001 From: Andrew Carbonetto Date: Sat, 29 Jun 2024 15:47:16 -0700 Subject: [PATCH] #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 6112bb08a5..51fa66c4c7 100644 --- a/java/integTest/src/test/java/glide/SharedCommandTests.java +++ b/java/integTest/src/test/java/glide/SharedCommandTests.java @@ -4374,6 +4374,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 c1a2e2a6fb..6af33c87cd 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 )