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

Always log when a lambda is invoked

Browse Source 
This replaces the previous single-purpose log about a link test
with a more informative and generic one for all invocations.
This commit is contained in:
Ben Thorner
2021-07-19 14:34:35 +01:00
parent 1e8eda0d15
commit 7fb65761f9
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/celery/broadcast_message_tasks.py
View File

@@ -251,6 +251,4 @@ def send_broadcast_provider_message(self, broadcast_event_id, provider):
@notify_celery.task(name='trigger-link-test') @notify_celery.task(name='trigger-link-test')
def trigger_link_test(provider): def trigger_link_test(provider):
identifier = str(uuid.uuid4()) identifier = str(uuid.uuid4())
message = f"Sending a link test to CBC proxy for provider {provider}. Identifier in payload is {identifier}"
current_app.logger.info(message)
cbc_proxy_client.get_proxy(provider).send_link_test(identifier) cbc_proxy_client.get_proxy(provider).send_link_test(identifier)

4
app/clients/cbc_proxy.py
View File

@@ -118,6 +118,10 @@ class CBCProxyClientBase(ABC):
def _invoke_lambda(self, lambda_name, payload): def _invoke_lambda(self, lambda_name, payload):
payload_bytes = bytes(json.dumps(payload), encoding='utf8') payload_bytes = bytes(json.dumps(payload), encoding='utf8')
try: try:
current_app.logger.info(
f"Calling lambda {lambda_name} for link test with payload {payload}"
)
result = self._lambda_client.invoke( result = self._lambda_client.invoke(
FunctionName=lambda_name, FunctionName=lambda_name,
InvocationType='RequestResponse', InvocationType='RequestResponse',