send callback success updates in parallel, and delay success to ensure invocation completes

Author: anthonyting

packages/aws-durable-execution-sdk-js-examples/src/examples/create-callback/concurrent/create-callback-concurrent.history.json

@@ -2,8 +2,8 @@
   {
     "EventType": "ExecutionStarted",
     "EventId": 1,
-    "Id": "baad178f-c918-474e-932a-7d0f8868e4be",
-    "EventTimestamp": "2025-12-10T00:15:09.988Z",
+    "Id": "ef61112a-8abb-4cb1-b4eb-e84df17b3eff",
+    "EventTimestamp": "2025-12-11T22:10:27.253Z",
     "ExecutionStartedDetails": {
       "Input": {
         "Payload": "{}"
@@ -16,9 +16,9 @@
     "EventId": 2,
     "Id": "c4ca4238a0b92382",
     "Name": "api-call-1",
-    "EventTimestamp": "2025-12-10T00:15:10.018Z",
+    "EventTimestamp": "2025-12-11T22:10:27.286Z",
     "CallbackStartedDetails": {
-      "CallbackId": "eyJleGVjdXRpb25JZCI6IjNlZWIyMjRlLWM2ZGMtNDMzZC04NjFhLWI2YzlhZTIzMjg3NSIsIm9wZXJhdGlvbklkIjoiYzRjYTQyMzhhMGI5MjM4MiIsInRva2VuIjoiM2RjNGQ0ZjAtZGM4OS00YThiLTgxZDgtMmExZDE2MTVhMGRkIn0=",
+      "CallbackId": "eyJleGVjdXRpb25JZCI6ImY5MmRjZDMzLTE1NTEtNDg2OS04ZDhmLTVkY2E1ZmMzNjM0YyIsIm9wZXJhdGlvbklkIjoiYzRjYTQyMzhhMGI5MjM4MiIsInRva2VuIjoiYmMxM2U4MjYtNmIyZC00MzQyLThjOTYtNDg1MmM1NDhjNTk2In0=",
       "Timeout": 300,
       "Input": {}
     }
@@ -29,9 +29,9 @@
     "EventId": 3,
     "Id": "c81e728d9d4c2f63",
     "Name": "api-call-2",
-    "EventTimestamp": "2025-12-10T00:15:10.039Z",
+    "EventTimestamp": "2025-12-11T22:10:27.307Z",
     "CallbackStartedDetails": {
-      "CallbackId": "eyJleGVjdXRpb25JZCI6IjNlZWIyMjRlLWM2ZGMtNDMzZC04NjFhLWI2YzlhZTIzMjg3NSIsIm9wZXJhdGlvbklkIjoiYzgxZTcyOGQ5ZDRjMmY2MyIsInRva2VuIjoiMjAwMjczNzMtNWM0Zi00OGY2LTg0NTEtODc4MmM5Njg4ZTNiIn0=",
+      "CallbackId": "eyJleGVjdXRpb25JZCI6ImY5MmRjZDMzLTE1NTEtNDg2OS04ZDhmLTVkY2E1ZmMzNjM0YyIsIm9wZXJhdGlvbklkIjoiYzgxZTcyOGQ5ZDRjMmY2MyIsInRva2VuIjoiY2EyOWZmYWQtZDMyMi00YmQ1LTlkNGMtNGY4ZjAxYTk2MjI1In0=",
       "Timeout": 300,
       "Input": {}
     }
@@ -42,20 +42,31 @@
     "EventId": 4,
     "Id": "eccbc87e4b5ce2fe",
     "Name": "api-call-3",
-    "EventTimestamp": "2025-12-10T00:15:10.067Z",
+    "EventTimestamp": "2025-12-11T22:10:27.327Z",
     "CallbackStartedDetails": {
-      "CallbackId": "eyJleGVjdXRpb25JZCI6IjNlZWIyMjRlLWM2ZGMtNDMzZC04NjFhLWI2YzlhZTIzMjg3NSIsIm9wZXJhdGlvbklkIjoiZWNjYmM4N2U0YjVjZTJmZSIsInRva2VuIjoiZTAyMTdlNWItMDQyZS00MmRjLWEwNmEtZGFkMzQ4ZjgzNzQwIn0=",
+      "CallbackId": "eyJleGVjdXRpb25JZCI6ImY5MmRjZDMzLTE1NTEtNDg2OS04ZDhmLTVkY2E1ZmMzNjM0YyIsIm9wZXJhdGlvbklkIjoiZWNjYmM4N2U0YjVjZTJmZSIsInRva2VuIjoiYjAzNTJkYTItMjlhNy00NjViLWI1ZDItNzdjMDgxOTI1MzBlIn0=",
       "Timeout": 300,
       "Input": {}
     }
   },
+  {
+    "EventType": "InvocationCompleted",
+    "EventId": 5,
+    "EventTimestamp": "2025-12-11T22:10:27.347Z",
+    "InvocationCompletedDetails": {
+      "StartTimestamp": "2025-12-11T22:10:27.253Z",
+      "EndTimestamp": "2025-12-11T22:10:27.347Z",
+      "Error": {},
+      "RequestId": "87f8f141-1f5f-456f-b2ce-332246be3e33"
+    }
+  },
   {
     "EventType": "CallbackSucceeded",
     "SubType": "Callback",
-    "EventId": 5,
+    "EventId": 6,
     "Id": "c81e728d9d4c2f63",
     "Name": "api-call-2",
-    "EventTimestamp": "2025-12-10T00:15:10.070Z",
+    "EventTimestamp": "2025-12-11T22:10:27.431Z",
     "CallbackSucceededDetails": {
       "Result": {
         "Payload": "{\"id\":2,\"data\":\"second\"}"
@@ -65,10 +76,10 @@
   {
     "EventType": "CallbackSucceeded",
     "SubType": "Callback",
-    "EventId": 6,
+    "EventId": 7,
     "Id": "c4ca4238a0b92382",
     "Name": "api-call-1",
-    "EventTimestamp": "2025-12-10T00:15:10.071Z",
+    "EventTimestamp": "2025-12-11T22:10:27.432Z",
     "CallbackSucceededDetails": {
       "Result": {
         "Payload": "{\"id\":1,\"data\":\"first\"}"
@@ -78,43 +89,32 @@
   {
     "EventType": "CallbackSucceeded",
     "SubType": "Callback",
-    "EventId": 7,
+    "EventId": 8,
     "Id": "eccbc87e4b5ce2fe",
     "Name": "api-call-3",
-    "EventTimestamp": "2025-12-10T00:15:10.075Z",
+    "EventTimestamp": "2025-12-11T22:10:27.432Z",
     "CallbackSucceededDetails": {
       "Result": {
         "Payload": "{\"id\":3,\"data\":\"third\"}"
       }
     }
   },
-  {
-    "EventType": "InvocationCompleted",
-    "EventId": 8,
-    "EventTimestamp": "2025-12-10T00:15:10.126Z",
-    "InvocationCompletedDetails": {
-      "StartTimestamp": "2025-12-10T00:15:09.987Z",
-      "EndTimestamp": "2025-12-10T00:15:10.126Z",
-      "Error": {},
-      "RequestId": "6f2132e4-4618-4e08-88c0-9819e79685ca"
-    }
-  },
   {
     "EventType": "InvocationCompleted",
     "EventId": 9,
-    "EventTimestamp": "2025-12-10T00:15:10.146Z",
+    "EventTimestamp": "2025-12-11T22:10:27.453Z",
     "InvocationCompletedDetails": {
-      "StartTimestamp": "2025-12-10T00:15:10.146Z",
-      "EndTimestamp": "2025-12-10T00:15:10.146Z",
+      "StartTimestamp": "2025-12-11T22:10:27.452Z",
+      "EndTimestamp": "2025-12-11T22:10:27.453Z",
       "Error": {},
-      "RequestId": "7b23a50d-1b08-47d5-96ed-473f84c01ffd"
+      "RequestId": "9f51c6e9-d21b-4ba7-be12-2ced22ae2f29"
     }
   },
   {
     "EventType": "ExecutionSucceeded",
     "EventId": 10,
-    "Id": "baad178f-c918-474e-932a-7d0f8868e4be",
-    "EventTimestamp": "2025-12-10T00:15:10.147Z",
+    "Id": "ef61112a-8abb-4cb1-b4eb-e84df17b3eff",
+    "EventTimestamp": "2025-12-11T22:10:27.453Z",
     "ExecutionSucceededDetails": {
       "Result": {
         "Payload": "{\"results\":[\"{\\\"id\\\":1,\\\"data\\\":\\\"first\\\"}\",\"{\\\"id\\\":2,\\\"data\\\":\\\"second\\\"}\",\"{\\\"id\\\":3,\\\"data\\\":\\\"third\\\"}\"],\"allCompleted\":true}"

packages/aws-durable-execution-sdk-js-examples/src/examples/create-callback/concurrent/create-callback-concurrent.test.ts

@@ -25,22 +25,27 @@ createTests({
         callback3.waitForData(WaitingOperationStatus.STARTED),
       ]);
 
+      // Wait a bit to ensure invocations complete (TODO: add a waitForInvocation to testing lib)
+      await new Promise((resolve) => setTimeout(resolve, 100));
+
       // Complete callbacks in different order
       const callbackResult2 = JSON.stringify({
         id: 2,
         data: "second",
       });
-      await callback2.sendCallbackSuccess(callbackResult2);
       const callbackResult1 = JSON.stringify({
         id: 1,
         data: "first",
       });
-      await callback1.sendCallbackSuccess(callbackResult1);
       const callbackResult3 = JSON.stringify({
         id: 3,
         data: "third",
       });
-      await callback3.sendCallbackSuccess(callbackResult3);
+      await Promise.all([
+        callback2.sendCallbackSuccess(callbackResult2),
+        callback1.sendCallbackSuccess(callbackResult1),
+        callback3.sendCallbackSuccess(callbackResult3),
+      ]);
 
       const result = await executionPromise;