Add sample worker for failing

orkes-io · Sep 27, 2023 · 11c878f · 11c878f
1 parent db48a5c
commit 11c878f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/io/orkes/samples/workers/FailNTimesWorker.java b/src/main/java/io/orkes/samples/workers/FailNTimesWorker.java
@@ -28,6 +28,7 @@ public TaskResult execute(Task task) {
         if(failedCount >= timesToFail) {
             result.addOutputData("outputVal", "This task completed failing for configured number of times - " + timesToFail);
             result.setStatus(TaskResult.Status.COMPLETED);
+            return result;
         }
         result.addOutputData("failedCount", ++failedCount);
         result.addOutputData("outputVal", "This task fails (for testing) for " + timesToFail + " times");