fix(cli): disable worker on standalone when 0

kestra-io · Dec 2, 2023 · 34c2f8f · 34c2f8f
1 parent 9ef5de2
commit 34c2f8f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/cli/src/main/java/io/kestra/cli/commands/servers/StandAloneCommand.java b/cli/src/main/java/io/kestra/cli/commands/servers/StandAloneCommand.java
@@ -65,7 +65,9 @@ public Integer call() throws Exception {
 
         StandAloneRunner standAloneRunner = applicationContext.getBean(StandAloneRunner.class);
 
-        if (this.workerThread != null) {
+        if (this.workerThread != null  && this.workerThread == 0) {
+            standAloneRunner.setWorkerEnabled(false);
+        } else if (this.workerThread != null) {
             standAloneRunner.setWorkerThread(this.workerThread);
         }
 

diff --git a/core/src/main/java/io/kestra/core/runners/StandAloneRunner.java b/core/src/main/java/io/kestra/core/runners/StandAloneRunner.java
@@ -53,7 +53,7 @@ public void run() {
 
         poolExecutor.execute(applicationContext.getBean(ExecutorInterface.class));
 
-        if(workerEnabled) {
+        if (workerEnabled) {
             Worker worker = new Worker(applicationContext, workerThread, null);
             applicationContext.registerSingleton(worker);
             poolExecutor.execute(worker);