Throw exception on Lambda function error (#130)

agorapulse · Nov 29, 2022 · 3a76d22 · 3a76d22
1 parent 0bb457b
commit 3a76d22
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...src/main/java/com/agorapulse/micronaut/amazon/awssdk/lambda/LambdaClientIntroduction.java b/...src/main/java/com/agorapulse/micronaut/amazon/awssdk/lambda/LambdaClientIntroduction.java
@@ -109,7 +109,7 @@ private Object invokeFunction(MethodInvocationContext<Object, Object> context, s
 
             InvokeResponse response = service.invoke(request);
 
-            if (response.statusCode() >= 400) {
+            if (response.statusCode() >= 400 || StringUtils.isNotEmpty(response.functionError())) {
                 throw new LambdaClientException(response);
             }
 

diff --git a/...-lambda/src/main/groovy/com/agorapulse/micronaut/aws/lambda/LambdaClientIntroduction.java b/...-lambda/src/main/groovy/com/agorapulse/micronaut/aws/lambda/LambdaClientIntroduction.java
@@ -111,7 +111,7 @@ private Object invokeFunction(MethodInvocationContext<Object, Object> context, A
 
             InvokeResult response = service.invoke(request);
 
-            if (response.getStatusCode() >= 400) {
+            if (response.getStatusCode() >= 400 || StringUtils.isNotEmpty(response.getFunctionError())) {
                 throw new LambdaClientException(response);
             }