From af877132584d48af3383aa3a73845e9fd13698d4 Mon Sep 17 00:00:00 2001 From: "brian.mulier" Date: Wed, 26 Nov 2025 15:45:24 +0100 Subject: [PATCH] fix(tests): attempt to bump amount of executor threads in TestRunner --- .../main/java/io/kestra/core/junit/annotations/KestraTest.java | 2 +- .../io/kestra/core/junit/extensions/KestraTestExtension.java | 1 + tests/src/main/java/io/kestra/core/runners/TestRunner.java | 2 +- 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/tests/src/main/java/io/kestra/core/junit/annotations/KestraTest.java b/tests/src/main/java/io/kestra/core/junit/annotations/KestraTest.java index 22695b57f5..f3cfa29bc5 100644 --- a/tests/src/main/java/io/kestra/core/junit/annotations/KestraTest.java +++ b/tests/src/main/java/io/kestra/core/junit/annotations/KestraTest.java @@ -47,4 +47,4 @@ public @interface KestraTest { boolean startApplication() default true; boolean resolveParameters() default true; -} \ No newline at end of file +} diff --git a/tests/src/main/java/io/kestra/core/junit/extensions/KestraTestExtension.java b/tests/src/main/java/io/kestra/core/junit/extensions/KestraTestExtension.java index affaefb451..aa15c92154 100644 --- a/tests/src/main/java/io/kestra/core/junit/extensions/KestraTestExtension.java +++ b/tests/src/main/java/io/kestra/core/junit/extensions/KestraTestExtension.java @@ -11,6 +11,7 @@ import org.junit.platform.commons.support.AnnotationSupport; public class KestraTestExtension extends MicronautJunit5Extension { @Override protected MicronautTestValue buildMicronautTestValue(Class testClass) { + testProperties.put("kestra.jdbc.executor.thread-count", Runtime.getRuntime().availableProcessors() * 4); return AnnotationSupport .findAnnotation(testClass, KestraTest.class) .map(kestraTestAnnotation -> new MicronautTestValue( diff --git a/tests/src/main/java/io/kestra/core/runners/TestRunner.java b/tests/src/main/java/io/kestra/core/runners/TestRunner.java index b9a78e4e13..82db494761 100644 --- a/tests/src/main/java/io/kestra/core/runners/TestRunner.java +++ b/tests/src/main/java/io/kestra/core/runners/TestRunner.java @@ -25,7 +25,7 @@ import java.util.concurrent.atomic.AtomicBoolean; @Slf4j @Singleton public class TestRunner implements Runnable, AutoCloseable { - @Setter private int workerThread = Math.max(3, Runtime.getRuntime().availableProcessors()) * 16; + @Setter private int workerThread = Math.max(3, Runtime.getRuntime().availableProcessors()) * 4; @Setter private boolean schedulerEnabled = true; @Setter private boolean workerEnabled = true;