From 72edb2342ca7c97e5c3bd06320c08389d5de6a1d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Nicol=C3=B2=20Boschi?= Date: Mon, 20 May 2024 17:18:26 +0200 Subject: [PATCH] flaky test --- .../ai/langstream/apigateway/http/GatewayResourceTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java b/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java index 4d06e7509..a347c7187 100644 --- a/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java +++ b/langstream-api-gateway/src/test/java/ai/langstream/apigateway/http/GatewayResourceTest.java @@ -570,8 +570,7 @@ void testService() throws Exception { url, "{\"key\": \"my-key2\", \"value\": \"my-value\", \"headers\": {\"header1\":\"value1\"}}")); - // sorry but kafka can't keep up - final int numParallel = getStreamingCluster().type().equals("kafka") ? 5 : 30; + final int numParallel = 10; List> futures1 = new ArrayList<>(); for (int i = 0; i < numParallel; i++) { @@ -589,7 +588,7 @@ void testService() throws Exception { futures1.add(future); } CompletableFuture.allOf(futures1.toArray(new CompletableFuture[] {})) - .get(2, TimeUnit.MINUTES); + .get(3, TimeUnit.MINUTES); } private void startTopicExchange(String logicalFromTopic, String logicalToTopic)