test: Added wait for live key exclude

redis · Jul 10, 2023 · a7fecb5 · a7fecb5
1 parent 1e78fd7
commit a7fecb5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugins/riot/src/test/java/com/redis/riot/cli/AbstractIntegrationTests.java b/plugins/riot/src/test/java/com/redis/riot/cli/AbstractIntegrationTests.java
@@ -777,8 +777,8 @@ void replicateLiveKeyExclude() throws Throwable {
 			}
 		}, 500, TimeUnit.MILLISECONDS);
 		execute(filename);
-		Assertions.assertEquals(badCount, connection.sync().keys("bad:*").size());
-		Assertions.assertEquals(goodCount, targetConnection.sync().keys("gen:*").size());
+		awaitUntil(() -> connection.sync().keys("bad:*").size() == badCount);
+		awaitUntil(() -> targetConnection.sync().keys("gen:*").size() == goodCount);
 	}
 
 	@Test