Data update: Improve failure tolerance and retry in price update

nico-corthorn · Oct 7, 2024 · 0d50471 · 0d50471
1 parent fe73e99
commit 0d50471
Showing 1 changed file with 20 additions and 2 deletions.
diff --git a/statemachine/update_all_prices.asl.json b/statemachine/update_all_prices.asl.json
@@ -12,13 +12,31 @@
             "ItemsPath": "$.assets",
             "MaxConcurrency": 10,
             "ToleratedFailureCount": 10,
-            "Iterator":
-            {
+            "Iterator": {
                 "StartAt": "Update Prices",
                 "States": {
                     "Update Prices": {
                         "Type": "Task",
                         "Resource": "${UpdatePricesFunctionArn}",
+                        "Retry": [
+                            {
+                                "ErrorEquals": ["States.ALL"],
+                                "IntervalSeconds": 60,
+                                "MaxAttempts": 5,
+                                "BackoffRate": 2
+                            }
+                        ],
+                        "Catch": [
+                            {
+                                "ErrorEquals": ["States.ALL"],
+                                "ResultPath": "$.errorInfo",
+                                "Next": "Proceed After Failure"
+                            }
+                        ],
+                        "End": true
+                    },
+                    "Proceed After Failure": {
+                        "Type": "Pass",
                         "End": true
                     }
                 }