Skip to content

Commit

Permalink
fix(core): fail the worker if it receives directly a flowable task in…
Browse files Browse the repository at this point in the history
…stead of silently doing nothing
  • Loading branch information
loicmathieu authored and tchiotludo committed May 29, 2023
1 parent ec733c5 commit 8df977b
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions core/src/main/java/io/kestra/core/runners/Worker.java
Original file line number Diff line number Diff line change
Expand Up @@ -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");
}
});
}
);
Expand Down

0 comments on commit 8df977b

Please sign in to comment.