Merge branch 'main' into chore/cloud-testing

Author: SilanHe

.github/dependabot.yml

@@ -0,0 +1,27 @@
+version: 2
+updates:
+  - package-ecosystem: "maven"
+    directory: "/"
+    schedule:
+      interval: "daily"
+      time: "09:00"
+      timezone: "UTC"
+    open-pull-requests-limit: 5
+    commit-message:
+      prefix: "[maven]"
+    labels:
+      - "dependencies"
+      - "java"
+
+  - package-ecosystem: "github-actions"
+    directory: "/.github/workflows"
+    schedule:
+      interval: "daily"
+      time: "09:00"
+      timezone: "UTC"
+    open-pull-requests-limit: 5
+    commit-message:
+      prefix: "[github-actions]"
+    labels:
+      - "dependencies"
+      - "github-actions"

.github/workflows/build.yml

@@ -48,7 +48,7 @@ jobs:
           - 25
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
 
       - name: Setup Java ${{ matrix.java }}
         uses: actions/setup-java@v5

.github/workflows/check-spotless.yml

@@ -27,7 +27,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
 
       - name: Set up JDK 17
         uses: actions/setup-java@v5

.github/workflows/sync-package.yml

@@ -33,7 +33,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Git clone the repository
-        uses: actions/checkout@v5
+        uses: actions/checkout@v6
       - name: Set up JDK 17
         uses: actions/setup-java@v5
         with:
@@ -50,7 +50,7 @@ jobs:
       - name: Build with Maven
         run: mvn -B package --file pom.xml
       - name: configure aws credentials
-        uses: aws-actions/configure-aws-credentials@e3dd6a429d7300a6a4c196c26e071d42e0343502
+        uses: aws-actions/configure-aws-credentials@8df5847569e6427dd6c4fb1cf565c83acfa8afa7
         with:
           role-to-assume: "${{ secrets.ACTIONS_SYNC_ROLE_NAME }}"
           role-session-name: samplerolesession

README.md

@@ -384,13 +384,22 @@ protected DurableConfig createConfiguration() {
 
 The SDK throws specific exceptions to help you handle different failure scenarios:
 
-| Exception | When Thrown | How to Handle |
-|-----------|-------------|---------------|
-| `StepFailedException` | Step exhausted all retry attempts | Catch to implement fallback logic or let execution fail |
-| `StepInterruptedException` | `AT_MOST_ONCE` step was interrupted before completion | Implement manual recovery (check if operation completed externally) |
-| `CallbackTimeoutException` | Callback exceeded its timeout duration | Implement fallback logic or escalation |
-| `CallbackFailedException` | External system sent an error response to the callback | Handle the error or propagate failure |
-| `NonDeterministicExecutionException` | Code changed between original execution and replay | Fix code to maintain determinism; don't change step order/names |
+```
+DurableExecutionException              - General durable exception
+├── NonDeterministicExecutionException - Code changed between original execution and replay. Fix code to maintain determinism; don't change step order/names.
+├── SerDesException                    - Serialization and deserialization exception.
+└── DurableOperationException          - General operation exception
+    ├── StepException                  - General Step exception
+    │   ├── StepFailedException        - Step exhausted all retry attempts.Catch to implement fallback logic or let execution fail.
+    │   └── StepInterruptedException   - `AT_MOST_ONCE` step was interrupted before completion. Implement manual recovery (check if operation completed externally)
+    ├── InvokeException                - General chained invocation exception
+    │   ├── InvokeFailedException      - Chained invocation failed. Handle the error or propagate failure.
+    │   ├── InvokeTimedoutException    - Chained invocation timed out. Handle the error or propagate failure.
+    │   └── InvokeStoppedException     - Chained invocation stopped. Handle the error or propagate failure.
+    └── CallbackException              - General callback exception
+        ├── CallbackFailedException    - External system sent an error response to the callback. Handle the error or propagate failure
+        └── CallbackTimeoutException   - Callback exceeded its timeout duration. Handle the error or propagate the failure
+```
 
 ```java
 try {

examples/pom.xml

@@ -77,7 +77,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-shade-plugin</artifactId>
-                <version>3.5.1</version>
+                <version>3.6.1</version>
                 <configuration>
                     <createDependencyReducedPom>false</createDependencyReducedPom>
                 </configuration>

examples/src/main/java/com/amazonaws/lambda/durable/examples/ErrorHandlingExample.java

@@ -6,6 +6,7 @@
 import com.amazonaws.lambda.durable.DurableHandler;
 import com.amazonaws.lambda.durable.StepConfig;
 import com.amazonaws.lambda.durable.StepSemantics;
+import com.amazonaws.lambda.durable.exception.StepFailedException;
 import com.amazonaws.lambda.durable.exception.StepInterruptedException;
 import com.amazonaws.lambda.durable.retry.RetryStrategies;
 import org.slf4j.Logger;
@@ -85,7 +86,9 @@ public String handleRequest(Object input, DurableContext context) {
                             .semantics(StepSemantics.AT_MOST_ONCE_PER_RETRY)
                             .build());
         } catch (StepInterruptedException e) {
-            logger.warn("Payment step interrupted, checking external status: {}", e.getOperationId());
+            logger.warn(
+                    "Payment step interrupted, checking external status: {}",
+                    e.getOperation().id());
             // In real code: check payment provider for transaction status
             // If payment went through, return success; otherwise, handle appropriately
             paymentResult = context.step("verify-payment-status", String.class, () -> "verified-payment");

examples/src/test/java/com/amazonaws/lambda/durable/examples/CloudBasedIntegrationTest.java

@@ -68,6 +68,23 @@ void testSimpleStepExample() {
         assertEquals("create-greeting", createGreetingOp.getName());
     }
 
+    @Test
+    void testSimpleInvokeExample() {
+        var runner = CloudDurableTestRunner.create(arn("simple-invoke-example"), Map.class, String.class);
+        var result = runner.run(Map.of("message", "test"));
+
+        assertEquals(ExecutionStatus.SUCCEEDED, result.getStatus());
+        assertNotNull(result.getResult(String.class));
+
+        var createGreetingOp = runner.getOperation("call-greeting1");
+        assertNotNull(createGreetingOp);
+        assertEquals("call-greeting1", createGreetingOp.getName());
+
+        var createGreetingOp2 = runner.getOperation("call-greeting2");
+        assertNotNull(createGreetingOp);
+        assertEquals("call-greeting2", createGreetingOp2.getName());
+    }
+
     @Test
     void testRetryExample() {
         var runner = CloudDurableTestRunner.create(arn("retry-example"), String.class, String.class);

examples/template.yaml

@@ -37,13 +37,6 @@ Resources:
       DurableConfig:
         ExecutionTimeout: 300
         RetentionPeriodInDays: 7
-      Policies:
-        - Statement:
-            - Effect: Allow
-              Action:
-                - lambda:CheckpointDurableExecutions
-                - lambda:GetDurableExecutionState
-              Resource: !Sub "arn:aws:lambda:${AWS::Region}:${AWS::AccountId}:function:simple-step-example"
     Metadata:
       Dockerfile: !Ref DockerFile
       DockerContext: ../

pom.xml

@@ -23,13 +23,13 @@
         <maven.compiler.source>17</maven.compiler.source>
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <aws.sdk.version>2.40.16</aws.sdk.version>
-        <jackson.version>2.20.0</jackson.version>
-        <junit.version>5.14.1</junit.version>
-        <mockito.version>5.20.0</mockito.version>
+        <aws.sdk.version>2.41.25</aws.sdk.version>
+        <jackson.version>2.21.0</jackson.version>
+        <junit.version>6.0.2</junit.version>
+        <mockito.version>5.21.0</mockito.version>
         <slf4j.version>2.0.17</slf4j.version>
         <jacoco.version>0.8.14</jacoco.version>
-        <spotless.version>3.1.0</spotless.version>
+        <spotless.version>3.2.1</spotless.version>
     </properties>
 
     <dependencyManagement>
@@ -87,7 +87,7 @@
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-compiler-plugin</artifactId>
-                    <version>3.14.1</version>
+                    <version>3.15.0</version>
                 </plugin>
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>