feat(sdk): Add executionStartTimestamp to InvocationBaseInfo

packages/aws-durable-execution-sdk-js-otel/src/__tests__/context-extractors.test.ts

@@ -12,6 +12,7 @@ const baseInfo: InvocationInfo = {
   executionInput: {},
   operations: {},
   updatedOperations: {},
+  executionStartTimestamp: new Date("2024-01-01T00:00:00Z"),
 };
 
 describe("xRayContextExtractor", () => {

packages/aws-durable-execution-sdk-js-otel/src/__tests__/plugin.test.ts

@@ -42,6 +42,7 @@ function makeInvocationInfo(
     executionInput: {},
     operations: {},
     updatedOperations: {},
+    executionStartTimestamp: new Date("2024-01-01T00:00:00Z"),
     ...overrides,
   };
 }
@@ -57,6 +58,7 @@ function makeInvocationEndInfo(
     status: "SUCCEEDED" as any,
     executionResult: undefined,
     executionError: undefined,
+    executionStartTimestamp: new Date("2024-01-01T00:00:00Z"),
     ...overrides,
   };
 }

packages/aws-durable-execution-sdk-js/src/types/plugin.ts

@@ -121,6 +121,12 @@ export interface InvocationBaseInfo {
   executionArn: string;
   executionInput: unknown;
   operations: Record<string, OperationInfo>;
+  /**
+   * The timestamp when the overall durable execution was first started,
+   * as reported by the backend. This remains the same across all
+   * invocations (including replays) of a given execution.
+   */
+  executionStartTimestamp?: Date;
 }
 
 /**

packages/aws-durable-execution-sdk-js/src/utils/plugin/plugin-runner.test.ts

@@ -28,6 +28,7 @@ describe("createPluginRunner", () => {
     executionInput: { test: true },
     operations: {},
     updatedOperations: {},
+    executionStartTimestamp: new Date("2024-01-01T00:00:00Z"),
   };
 
   const operationInfo: OperationInfo = {
@@ -723,6 +724,7 @@ describe("createPluginRunner", () => {
       executionResult: { data: "test" },
       executionInput: { event: "input" },
       operations: {},
+      executionStartTimestamp: new Date("2024-01-01T00:00:00Z"),
     };
 
     it.each([

packages/aws-durable-execution-sdk-js/src/with-durable-execution.plugin.test.ts

@@ -39,7 +39,14 @@ const mockTerminationManager = {
   setCheckpointTerminatingCallback: jest.fn(),
 };
 const mockExecutionContext = {
-  _stepData: {},
+  _stepData: {
+    "initial-op": {
+      StartTimestamp: new Date("2024-06-01T12:00:00Z"),
+      ExecutionDetails: {
+        InputPayload: "{}",
+      },
+    },
+  },
   durableExecutionArn: "arn:test",
   requestId: "req-123",
   terminationManager: mockTerminationManager,
@@ -89,6 +96,7 @@ describe("plugin hooks", () => {
       executionInput: expect.anything(),
       operations: expect.any(Object),
       updatedOperations: expect.any(Object),
+      executionStartTimestamp: new Date("2024-06-01T12:00:00Z"),
     });
   });
 
@@ -111,6 +119,7 @@ describe("plugin hooks", () => {
       executionInput: expect.anything(),
       operations: expect.any(Object),
       updatedOperations: expect.any(Object),
+      executionStartTimestamp: new Date("2024-06-01T12:00:00Z"),
     });
   });
 

packages/aws-durable-execution-sdk-js/src/with-durable-execution.ts

@@ -95,6 +95,7 @@ async function runHandler<
     executionArn: executionContext.durableExecutionArn,
     executionInput: customerHandlerEvent,
     operations: allOperations,
+    executionStartTimestamp: initialExecutionEvent?.StartTimestamp ?? undefined,
   };
 
   const invocationInfo: InvocationInfo = {