From 8df977baf86ca4e6cb895ccb98f8bedc3208b8f4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lo=C3=AFc=20Mathieu?= <loikeseke@gmail.com>
Date: Mon, 29 May 2023 11:05:55 +0200
Subject: [PATCH] fix(core): fail the worker if it receives directly a flowable
 task instead of silently doing nothing

---
 core/src/main/java/io/kestra/core/runners/Worker.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/core/src/main/java/io/kestra/core/runners/Worker.java b/core/src/main/java/io/kestra/core/runners/Worker.java
index fe2ff30c5cc..f50b428e4e1 100644
--- a/core/src/main/java/io/kestra/core/runners/Worker.java
+++ b/core/src/main/java/io/kestra/core/runners/Worker.java
@@ -134,6 +134,9 @@ public void run() {
                             runContext.cleanup();
                         }
                     }
+                    else {
+                        throw new RuntimeException("Unable to process the task '" + workerTask.getTask().getId() + "' as it's not a runnable task");
+                    }
                 });
             }
         );