assert payload

it/runtime-v2/src/test/java/com/walmartlabs/concord/it/runtime/v2/ProcessIT.java

@@ -736,14 +736,15 @@ public void testThrowParallelWithPayload() throws Exception {
                 .archive(resource("parallelExceptionPayload"));
 
         ConcordProcess proc = concord.processes().start(payload);
-        expectStatus(proc, ProcessEntry.StatusEnum.FAILED);
+        expectStatus(proc, ProcessEntry.StatusEnum.FINISHED);
 
         // ---
         Map<String, Object> data = proc.getOutVariables();
-        List<Map<String, Object>> exceptions = (List<Map<String, Object>>) ConfigurationUtils.get(data, "lastError", "exceptions");
+        List<Map<String, Object>> exceptions = (List<Map<String, Object>>) ConfigurationUtils.get(data, "exceptions");
 
         assertNotNull(exceptions);
         assertEquals(List.of("BOOM1", "BOOM2"), exceptions.stream().map(e -> e.get("message")).toList());
+        assertEquals(List.of(Map.of("key", 1), Map.of("key", 2)), exceptions.stream().map(e -> e.get("payload")).toList());
     }
 
     private List<ProcessEventEntry> getProcessElementEvents(ConcordProcess proc) throws Exception {

it/runtime-v2/src/test/resources/com/walmartlabs/concord/it/runtime/v2/parallelExceptionPayload/concord.yml

@@ -1,17 +1,22 @@
 configuration:
   runtime: "concord-v2"
+  out:
+    - exceptions
 
 flows:
   default:
-    - block:
-      - task: "throw"
-        in:
-          exception: "BOOM${item}"
-          payload:
-            key: "${item}"
-      loop:
-        items:
+  - try:
+    - task: "throw"
+      in:
+        exception: "BOOM${item}"
+        payload:
+          key: "${item}"
+    loop:
+      items:
         - 1
         - 2
-        mode: parallel
-        parallelism: 2
+      mode: parallel
+      parallelism: 2
+    error:
+      - set:
+          exceptions: ${lastError.cause.exceptions.stream().map(e -> e.cause).toList()}