fix(parser): fix DynamoDB Stream Lambda invocation record model (#8321)

* fix(parser): fix DynamoDB Stream Lambda invocation record model

The responseContext.functionError field is null if the error did not
occur during function execution.

* chore: fix ruff B905 errors

* chore: bump ruff target version to 3.10

Also add temporary ignores for some upgrade rules, as there are 1017
corresponding errors.

---------

Co-authored-by: Leandro Damascena <lcdama@amazon.pt>

Author: exg

aws_lambda_powertools/event_handler/events_appsync/appsync_events.py

@@ -321,7 +321,7 @@ async def _call_publish_event_async_resolver(
                     if isinstance(ret, Exception)
                     else {"id": e.get("id"), "payload": ret}
                 )
-                for e, ret in zip(self.current_event.events, results)
+                for e, ret in zip(self.current_event.events, results, strict=True)
             ],
         )
 

aws_lambda_powertools/utilities/parser/models/dynamodb.py

@@ -175,7 +175,8 @@ class ResponseContext(BaseModel):
         description="The version of the Lambda executed",
         examples=["$LATEST"],
     )
-    function_error: str = Field(
+    function_error: Optional[str] = Field(
+        default=None,
         description="",
         examples=["Unhandled"],
     )

ruff.toml

@@ -41,6 +41,10 @@ lint.ignore = [
     "A005",
     "TC006", # https://docs.astral.sh/ruff/rules/runtime-cast-value/
     "PLC0415", # https://docs.astral.sh/ruff/rules/import-outside-top-level/
+    "UP006",
+    "UP007",
+    "UP035",
+    "UP045",
 ]
 
 # Exclude files and directories
@@ -62,7 +66,7 @@ exclude = [
 # Maximum line length
 line-length = 120
 
-target-version = "py38"
+target-version = "py310"
 
 fix = true
 lint.fixable = ["I", "COM812", "W"]

tests/unit/data_classes/required_dependencies/test_bedrock_agent_function_event.py

@@ -32,7 +32,7 @@ def test_bedrock_agent_function_event():
     raw_parameters = raw_event["parameters"]
     assert len(parameters) == len(raw_parameters)
 
-    for param, raw_param in zip(parameters, raw_parameters):
+    for param, raw_param in zip(parameters, raw_parameters, strict=True):
         assert param.name == raw_param["name"]
         assert param.type == raw_param["type"]
         assert param.value == raw_param["value"]

tests/unit/parser/_pydantic/test_dynamodb.py

@@ -1,3 +1,5 @@
+from typing import Any
+
 import pytest
 
 from aws_lambda_powertools.utilities.parser import ValidationError, envelopes, parse
@@ -86,8 +88,26 @@ def test_validate_event_does_not_conform_with_model():
         parse(event=raw_event, model=MyDynamoBusiness, envelope=envelopes.DynamoDBStreamEnvelope)
 
 
-def test_dynamo_db_stream_lambda_invocation_event():
+@pytest.mark.parametrize(
+    "response_context",
+    [
+        pytest.param(
+            {"statusCode": 200, "executedVersion": "$LATEST"},
+            id="without function error",
+        ),
+        pytest.param(
+            {"statusCode": 200, "executedVersion": "$LATEST", "functionError": None},
+            id="with null function error",
+        ),
+        pytest.param(
+            {"statusCode": 200, "executedVersion": "$LATEST", "functionError": "Unhandled"},
+            id="with function error",
+        ),
+    ],
+)
+def test_dynamo_db_stream_lambda_invocation_event(response_context: dict[str, Any]):
     raw_event = load_event("dynamoStreamLambdaInvocationEvent.json")
+    raw_event["responseContext"] = response_context
     parsed_event: DynamoDBStreamLambdaOnFailureDestinationModel = parse(
         event=raw_event,
         model=DynamoDBStreamLambdaOnFailureDestinationModel,
@@ -111,6 +131,8 @@ def test_dynamo_db_stream_lambda_invocation_event():
     )
     assert parsed_event.ddb_stream_batch_info.stream_arn == raw_event["DDBStreamBatchInfo"]["streamArn"]
     assert parsed_event.request_context.model_dump(by_alias=True) == raw_event["requestContext"]
-    assert parsed_event.response_context.model_dump(by_alias=True) == raw_event["responseContext"]
+    assert parsed_event.response_context.status_code == response_context["statusCode"]
+    assert parsed_event.response_context.executed_version == response_context["executedVersion"]
+    assert parsed_event.response_context.function_error == response_context.get("functionError")
     assert parsed_event.timestamp.strftime("%Y-%m-%dT%H:%M:%SZ") == raw_event["timestamp"]
     assert parsed_event.version == raw_event["version"]