From 21514efd719336e9e52d1a755e35ae803e029343 Mon Sep 17 00:00:00 2001 From: Tihomir Krasimirov Mateev Date: Tue, 30 Apr 2024 18:57:10 +0300 Subject: [PATCH] MAke sure we wait for the check so it does not fail on the slower pipeline (#2844) --- .../java/io/lettuce/core/RedisClientIntegrationTests.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java b/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java index 57eb8d2bbc..22a8671745 100644 --- a/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java +++ b/src/test/java/io/lettuce/core/RedisClientIntegrationTests.java @@ -139,7 +139,10 @@ void shouldPropagateCommandTimeoutToCommandListener() throws InterruptedExceptio assertThat(commandListener.succeeded).isEmpty(); Wait.untilTrue(() -> commandListener.failed.size() == 1); - assertThat(commandListener.failed).extracting(it -> it.getCommand().getType()).contains(CommandType.BLPOP); + Wait.untilTrue(() -> + commandListener.failed.stream().anyMatch(command -> + command.getCommand().getType().equals(CommandType.BLPOP))); + FastShutdown.shutdown(client); }