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"); + } }); } );