Fix: terminateReason in TERMINATE Task can use JSONPath expression to…

… extract value
Netflix · Sep 14, 2023 · 19c3c70 · 19c3c70
1 parent 6359617
commit 19c3c70
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java b/core/src/main/java/com/netflix/conductor/core/execution/WorkflowExecutor.java
@@ -458,14 +458,12 @@ private void endExecution(WorkflowModel workflow, TaskModel terminateTask) {
             String terminationStatus =
                     (String)
                             terminateTask
-                                    .getWorkflowTask()
-                                    .getInputParameters()
+                                    .getInputData()
                                     .get(Terminate.getTerminationStatusParameter());
             String reason =
                     (String)
                             terminateTask
-                                    .getWorkflowTask()
-                                    .getInputParameters()
+                                    .getInputData()
                                     .get(Terminate.getTerminationReasonParameter());
             if (StringUtils.isBlank(reason)) {
                 reason =