chore(version): update to version 'v0.4.2'.

.github/workflows/main.yml

@@ -23,7 +23,7 @@ jobs:
   check:
     name: Check & Publish
     runs-on: ubuntu-latest
-    timeout-minutes: 30
+    timeout-minutes: 45
     env:
       SLACK_WEBHOOK_URL: ${{ secrets.SLACK_WEBHOOK_URL }}
     steps:

core/src/main/java/io/kestra/core/runners/Worker.java

@@ -73,11 +73,7 @@ public Worker(ApplicationContext applicationContext, int thread) {
         this.metricRegistry = applicationContext.getBean(MetricRegistry.class);
 
         ExecutorsUtils executorsUtils = applicationContext.getBean(ExecutorsUtils.class);
-        this.executors = executorsUtils.maxCachedThreadPool(
-            Math.min(Runtime.getRuntime().availableProcessors(), thread),
-            thread,
-            "worker"
-        );
+        this.executors = executorsUtils.maxCachedThreadPool(thread,"worker");
     }
 
     @Override

core/src/main/java/io/kestra/core/utils/ExecutorsUtils.java

@@ -25,17 +25,21 @@ public ExecutorService cachedThreadPool(String name) {
         );
     }
 
-    public ExecutorService maxCachedThreadPool(int minThread, int maxThread, String name) {
+    public ExecutorService maxCachedThreadPool(int maxThread, String name) {
+        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
+            maxThread,
+            maxThread,
+            60L,
+            TimeUnit.SECONDS,
+            new LinkedBlockingQueue<>(),
+            threadFactoryBuilder.build(name + "_%d")
+        );
+
+        threadPoolExecutor.allowCoreThreadTimeOut(true);
+
         return this.wrap(
             name,
-            new ThreadPoolExecutor(
-                minThread,
-                maxThread,
-                60L,
-                TimeUnit.SECONDS,
-                new LinkedBlockingQueue<>(),
-                threadFactoryBuilder.build(name + "_%d")
-            )
+            threadPoolExecutor
         );
     }
 

docker-compose.yml

@@ -98,7 +98,7 @@ services:
               path: /tmp/kestra-wd/tmp
           url: http://localhost:8080/
     ports:
-      - "28080:8080"
+      - "8080:8080"
     depends_on:
       - kafka
       - zookeeper

gradle.properties

@@ -1,4 +1,4 @@
-version=0.4.1
+version=0.4.2
 opensearchVersion=1.2.4
 micronautVersion=3.3.4
 kafkaVersion=3.1.0