Merge pull request #143 from ghkdwlgns612/cancled-task

Fix Issue: notify cancelled task
conductor-oss · May 12, 2024 · 30e555c · 30e555c
2 parents 6aefcc0 + ca07ebe
commit 30e555c
Showing 1 changed file with 9 additions and 0 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
@@ -1203,6 +1203,15 @@ List<String> cancelNonTerminalTasks(WorkflowModel workflow) {
             if (!task.getStatus().isTerminal()) {
                 // Cancel the ones which are not completed yet....
                 task.setStatus(CANCELED);
+                try {
+                    notifyTaskStatusListener(task);
+                } catch (Exception e) {
+                    String errorMsg =
+                            String.format(
+                                    "Error while notifying TaskStatusListener: %s for workflow: %s",
+                                    task.getTaskId(), task.getWorkflowInstanceId());
+                    LOGGER.error(errorMsg, e);
+                }
                 if (systemTaskRegistry.isSystemTask(task.getTaskType())) {
                     WorkflowSystemTask workflowSystemTask =
                             systemTaskRegistry.get(task.getTaskType());