Merge branch 'awslabs:develop' into fix-1018

Author: Michael Brewer

CHANGELOG.md

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 This project follows [Keep a Changelog](https://keepachangelog.com/en/1.0.0/) format for changes and adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 
+## 1.25.1 - 2022-02-14
+
+### Bug Fixes
+
+**batch:** bugfix to clear exceptions between executions ([#1022](https://github.com/awslabs/aws-lambda-powertools-python/issues/1022))
+
 ## 1.25.0 - 2022-02-09
 
 ### Bug Fixes

aws_lambda_powertools/utilities/batch/base.py

@@ -351,6 +351,7 @@ def _prepare(self):
         """
         self.success_messages.clear()
         self.fail_messages.clear()
+        self.exceptions.clear()
         self.batch_response = copy.deepcopy(self.DEFAULT_RESPONSE)
 
     def _process_record(self, record: dict) -> Union[SuccessResponse, FailureResponse]:

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "aws_lambda_powertools"
-version = "1.25.0"
+version = "1.25.1"
 description = "A suite of utilities for AWS Lambda functions to ease adopting best practices such as tracing, structured logging, custom metrics, batching, idempotency, feature flags, and more."
 authors = ["Amazon Web Services"]
 include = ["aws_lambda_powertools/py.typed", "THIRD-PARTY-LICENSES"]

tests/functional/test_utilities_batch.py

@@ -895,8 +895,16 @@ def test_batch_processor_error_when_entire_batch_fails(sqs_event_factory, record
     def lambda_handler(event, context):
         return processor.response()
 
-    # WHEN/THEN
+    # WHEN calling `lambda_handler` in cold start
     with pytest.raises(BatchProcessingError) as e:
         lambda_handler(event, {})
-        ret = str(e)
-        assert ret is not None
+
+    # THEN raise BatchProcessingError
+    assert "All records failed processing. " in str(e.value)
+
+    # WHEN calling `lambda_handler` in warm start
+    with pytest.raises(BatchProcessingError) as e:
+        lambda_handler(event, {})
+
+    # THEN raise BatchProcessingError
+    assert "All records failed processing. " in str(e.value)