diff --git a/app/celery/broadcast_message_tasks.py b/app/celery/broadcast_message_tasks.py index 422feaa59..9c05cf35c 100644 --- a/app/celery/broadcast_message_tasks.py +++ b/app/celery/broadcast_message_tasks.py @@ -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) current_app.logger.info( - f'invoking cbc proxy to send ' - f'broadcast_event {broadcast_event.reference} ' + f'Invoking cbc proxy to send broadcast_provider_message with ID of {broadcast_provider_message.id} ' + f'and broadcast_event ID of {broadcast_event_id} ' f'msgType {broadcast_event.message_type}' ) @@ -215,8 +215,8 @@ def send_broadcast_provider_message(self, broadcast_event_id, provider): except CBCProxyRetryableException as exc: delay = get_retry_delay(self.request.retries) current_app.logger.exception( - f'Retrying send_broadcast_provider_message for broadcast_event {broadcast_event_id} and ' + - f'provider {provider} in {delay} seconds' + f'Retrying send_broadcast_provider_message for broadcast event {broadcast_event_id}, ' + f'provider message {broadcast_provider_message.id}, provider {provider} in {delay} seconds' ) self.retry( @@ -236,6 +236,6 @@ def trigger_link_test(provider): sequence = Sequence('broadcast_provider_message_number_seq') sequential_number = db.session.connection().execute(sequence) 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) cbc_proxy_client.get_proxy(provider).send_link_test(identifier, formatted_seq_number)