Wip

routific · Jul 31, 2023 · 032c21e · 032c21e
1 parent b7963f6
commit 032c21e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/core/events/SimpleActionProcessor.java b/core/src/main/java/com/netflix/conductor/core/events/SimpleActionProcessor.java
@@ -128,6 +128,7 @@ private Map<String, Object> completeTask(
         String taskId = (String) replaced.get("taskId");
         String taskRefName = (String) replaced.get("taskRefName");
         Boolean retry = Boolean.TRUE.equals(replaced.get("retry"));
+        String failReason = (String) replaced.get("failReason");
 
         TaskModel taskModel = null;
         if (StringUtils.isNotEmpty(taskId)) {
@@ -174,6 +175,8 @@ private Map<String, Object> completeTask(
 
         if (retry) {
             status = TaskModel.Status.FAILED;
+        } else if (status.equals(TaskModel.Status.FAILED_WITH_TERMINAL_ERROR) && failReason != null) {
+            taskModel.setReasonForIncompletion(failReason);
         }
 
         taskModel.setStatus(status);