darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2025-12-23 17:01:35 -05:00
Code Issues Packages Projects Releases Wiki Activity

Create logs for invoking and finishing lambda, and for retry.

Browse Source 
Those logs will give us extra visibility into lambda invocation
process.
This commit is contained in:
Pea Tyczynska
2021-01-12 12:06:49 +00:00
parent d7661abe81
commit 1aff854afd
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/clients/cbc_proxy.py
View File

@@ -114,6 +114,7 @@ class CBCProxyClientBase(ABC):
if 'FunctionError' in result:
if result['Payload']['errorType'] == "CBCNewConnectionError":
current_app.logger.info(f"Got CBCNewConnectionError for {self.lambda_name}, calling failover lambda")
result = self._invoke_lambda(self.failover_lambda_name, payload_bytes)
else:
raise CBCProxyException('Function exited with unhandled exception')
@@ -121,6 +122,7 @@ class CBCProxyClientBase(ABC):
return result
def _invoke_lambda(self, lambda_name, payload_bytes):
current_app.logger.info(f"Calling lambda {lambda_name}")
result = self._lambda_client.invoke(
FunctionName=lambda_name,
InvocationType='RequestResponse',
@@ -130,6 +132,7 @@ class CBCProxyClientBase(ABC):
if result['StatusCode'] > 299:
raise CBCProxyException('Could not invoke lambda')
current_app.logger.info(f"Finished calling lambda {lambda_name}")
return result
def infer_language_from(self, content):