[Fix #3789] Accept join node on compensation states (#3790)

apache · Nov 22, 2024 · 26f9c10 · 26f9c10
1 parent 4d1a3d7
commit 26f9c10
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 2 deletions.
diff --git a/...uilder/src/main/java/org/kie/kogito/serverless/workflow/parser/handlers/StateHandler.java b/...uilder/src/main/java/org/kie/kogito/serverless/workflow/parser/handlers/StateHandler.java
@@ -184,7 +184,7 @@ private WorkflowElementIdentifier handleCompensation(RuleFlowNodeContainerFactor
         Transition transition = compensation.getState().getTransition();
         compensation.handleTransitions(embeddedSubProcess, transition, compensation.getNode());
         compensation.handleConnections(embeddedSubProcess);
-        return compensation.getNode().getNode().getId();
+        return compensation.getOutgoingNode().getNode().getId();
     }
 
     public void handleState() {
@@ -335,6 +335,10 @@ private void connectEnd(RuleFlowNodeContainerFactory<?, ?> factory) {
         return node;
     }
 
+    public final NodeFactory<?, ?> getOutgoingNode() {
+        return outgoingNode;
+    }
+
     public S getState() {
         return state;
     }

diff --git a/...gito-quarkus-serverless-workflow-integration-test/src/main/resources/compensation.sw.json b/...gito-quarkus-serverless-workflow-integration-test/src/main/resources/compensation.sw.json
@@ -70,7 +70,18 @@
           "errorRef": "OddException",
           "transition": "OddHandler"
        }
-       ]
+       ],
+      "transition": "compensating_even_more"
+    },
+    {
+      "name": "compensating_even_more",
+      "usedForCompensation" : true,
+      "type": "parallel",
+      "branches": [
+         {"name": "branch1", "actions" :[]},
+         {"name": "branch2", "actions" :[]}
+
+      ]
     },
     { "name": "OddHandler",
        "type":"inject",