Change termination reason in DeciderService

c4lm · Feb 1, 2024 · 420ce94 · 420ce94
1 parent 3813331
commit 420ce94
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/core/src/main/java/com/netflix/conductor/core/execution/DeciderService.java b/core/src/main/java/com/netflix/conductor/core/execution/DeciderService.java
@@ -544,7 +544,12 @@ Optional<TaskModel> retry(
             }
             updateWorkflowOutput(workflow, task);
             if (StringUtils.isEmpty(task.getReasonForIncompletion())) {
-                task.setReasonForIncompletion("Terminated");
+                task.setReasonForIncompletion(
+                        String.format(
+                                "Terminated because %s.%s is %s",
+                                workflow.getWorkflowId(),
+                                task.getReferenceTaskName(),
+                                task.getStatus().name()));
             }
             throw new TerminateWorkflowException(task.getReasonForIncompletion(), status, task);
         }