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

Merge pull request #3216 from alphagov/bcast-logging

Browse Source 
Add detail to broadcast logging messages
This commit is contained in:
Katie Smith
2021-04-21 09:03:38 +01:00
committed by GitHub
parent fbd231cefd e6357c91c9
commit 7ab0403ae7
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/celery/broadcast_message_tasks.py
View File

@@ -163,8 +163,8 @@ def send_broadcast_provider_message(self, broadcast_event_id, provider):
formatted_message_number = format_sequential_number(broadcast_provider_message.message_number) formatted_message_number = format_sequential_number(broadcast_provider_message.message_number)
current_app.logger.info( current_app.logger.info(
f'invoking cbc proxy to send ' f'Invoking cbc proxy to send broadcast_provider_message with ID of {broadcast_provider_message.id} '
f'broadcast_event {broadcast_event.reference} ' f'and broadcast_event ID of {broadcast_event_id} '
f'msgType {broadcast_event.message_type}' f'msgType {broadcast_event.message_type}'
) )
@@ -215,8 +215,8 @@ def send_broadcast_provider_message(self, broadcast_event_id, provider):
except CBCProxyRetryableException as exc: except CBCProxyRetryableException as exc:
delay = get_retry_delay(self.request.retries) delay = get_retry_delay(self.request.retries)
current_app.logger.exception( current_app.logger.exception(
f'Retrying send_broadcast_provider_message for broadcast_event {broadcast_event_id} and ' + f'Retrying send_broadcast_provider_message for broadcast event {broadcast_event_id}, '
f'provider {provider} in {delay} seconds' f'provider message {broadcast_provider_message.id}, provider {provider} in {delay} seconds'
) )
self.retry( self.retry(
@@ -236,6 +236,6 @@ def trigger_link_test(provider):
sequence = Sequence('broadcast_provider_message_number_seq') sequence = Sequence('broadcast_provider_message_number_seq')
sequential_number = db.session.connection().execute(sequence) sequential_number = db.session.connection().execute(sequence)
formatted_seq_number = format_sequential_number(sequential_number) formatted_seq_number = format_sequential_number(sequential_number)
message = f"Sending a link test to CBC proxy for provider {provider} with ID {identifier}" message = f"Sending a link test to CBC proxy for provider {provider}. Identifier in payload is {identifier}"
current_app.logger.info(message) current_app.logger.info(message)
cbc_proxy_client.get_proxy(provider).send_link_test(identifier, formatted_seq_number) cbc_proxy_client.get_proxy(provider).send_link_test(identifier, formatted_seq_number)