Fixed retry configuration to prevent test timeouts in failure threshold exceeded tests

- Replaced incorrect 'retry' property with proper 'retryStrategy' function
- Limited retry attempts to 2 to prevent test timeouts (was previously using default 5 attempts)
- Added 1-second delay between retry attempts for consistent timing
- Tests now complete within 60-second timeout while maintaining correct behavior validation
- Both map failure threshold exceeded count and percentage tests now pass reliably

Author: ParidelPooya

packages/aws-durable-execution-sdk-js-examples/src/examples/map/failure-threshold-exceeded-count/map-failure-threshold-exceeded-count.ts

@@ -17,12 +17,23 @@ export const handler = withDurableExecution(
       "failure-threshold-items",
       items,
       async (ctx: DurableContext, item: number, index: number) => {
-        return await ctx.step(`process-${index}`, async () => {
-          if (item <= 3) {
-            throw new Error(`Item ${item} failed`);
-          }
-          return item * 2;
-        });
+        return await ctx.step(
+          `process-${index}`,
+          async () => {
+            if (item <= 3) {
+              throw new Error(`Item ${item} failed`);
+            }
+            return item * 2;
+          },
+          {
+            retryStrategy: (error: Error, attemptCount: number) => {
+              if (attemptCount >= 2) {
+                return { shouldRetry: false };
+              }
+              return { shouldRetry: true, delay: { seconds: 1 } };
+            },
+          },
+        );
       },
       {
         completionConfig: {

packages/aws-durable-execution-sdk-js-examples/src/examples/map/failure-threshold-exceeded-percentage/map-failure-threshold-exceeded-percentage.ts

@@ -18,12 +18,23 @@ export const handler = withDurableExecution(
       "failure-threshold-items",
       items,
       async (ctx: DurableContext, item: number, index: number) => {
-        return await ctx.step(`process-${index}`, async () => {
-          if (item <= 3) {
-            throw new Error(`Item ${item} failed`);
-          }
-          return item * 2;
-        });
+        return await ctx.step(
+          `process-${index}`,
+          async () => {
+            if (item <= 3) {
+              throw new Error(`Item ${item} failed`);
+            }
+            return item * 2;
+          },
+          {
+            retryStrategy: (error: Error, attemptCount: number) => {
+              if (attemptCount >= 2) {
+                return { shouldRetry: false };
+              }
+              return { shouldRetry: true, delay: { seconds: 1 } };
+            },
+          },
+        );
       },
       {
         completionConfig: {