Add high tolerance for failures

wri · Aug 13, 2024 · 833dd0a · 833dd0a
1 parent 914c259
commit 833dd0a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 2 deletions.
diff --git a/lambdas/list_tiled_analysis/src/lambda_function.py b/lambdas/list_tiled_analysis/src/lambda_function.py
@@ -17,7 +17,7 @@ def handler(event, context):
         LOGGER.info(f"Running analysis with parameters: {event}")
 
         query = event["query"]
-        fid = event.get["fid"]
+        fid = event["fid"]
         geojson = mapping(decode_geometry(event["geometry"]))
         data_environment = DataEnvironment(layers=event["environment"])
 

diff --git a/lambdas/preprocessing/src/lambda_function.py b/lambdas/preprocessing/src/lambda_function.py
@@ -22,7 +22,7 @@ def handler(event, context):
         LOGGER.info(f"Running preprocessing with parameters: {event}")
         fc: Optional[Dict] = event.get("feature_collection")
         uri: Optional[str] = event.get("uri")
-        id_field = event.get("id_field", "fid")  # Reasonable to use a default?
+        id_field = event.get("id_field", "fid")
 
         if fc is not None and uri is not None:
             raise Exception("Please specify GeoJSON via (only) one parameter!")

diff --git a/step_functions/process_list.json.tmpl b/step_functions/process_list.json.tmpl
@@ -78,6 +78,7 @@
       },
       "Label": "ProcessGeometry",
       "MaxConcurrency": 100,
+      "ToleratedFailurePercentage": 100,
       "ItemReader": {
           "Resource": "arn:aws:states:::s3:getObject",
           "ReaderConfig": {