darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-02-04 18:31:13 -05:00
Code Issues Packages Projects Releases Wiki Activity

Improve log message

Browse Source
This commit is contained in:
Rebecca Law
2018-03-09 12:01:08 +00:00
parent e95740a6b5
commit a3d04ca672
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/celery/service_callback_tasks.py
View File

@@ -73,7 +73,9 @@ def send_delivery_status_to_service(self, notification_id,
self.retry(queue=QueueNames.RETRY) self.retry(queue=QueueNames.RETRY)
except self.MaxRetriesExceededError: except self.MaxRetriesExceededError:
current_app.logger.exception( current_app.logger.exception(
'Retry: send_delivery_status_to_service has retried the max num of times') """Retry: send_delivery_status_to_service has retried the max num of times
for notification: {}""".format(notification_id)
)
def process_update_with_notification_id(self, notification_id): def process_update_with_notification_id(self, notification_id):
@@ -135,4 +137,7 @@ def process_update_with_notification_id(self, notification_id):
try: try:
self.retry(queue=QueueNames.RETRY) self.retry(queue=QueueNames.RETRY)
except self.MaxRetriesExceededError: except self.MaxRetriesExceededError:
current_app.logger.exception('Retry: send_delivery_status_to_service has retried the max num of times') current_app.logger.exception(
"""Retry: send_delivery_status_to_service has retried the max num of times
for notification: {}""".format(notification_id)
)

4
app/commands.py
View File

@@ -361,8 +361,8 @@ def replay_service_callbacks(file_name, service_id):
send_delivery_status_to_service.apply_async([str(n.id), encrypted_status_update], send_delivery_status_to_service.apply_async([str(n.id), encrypted_status_update],
queue=QueueNames.CALLBACKS) queue=QueueNames.CALLBACKS)
print("Replay service status for service: {}. Sent {} notification status updates".format(service_id, print("Replay service status for service: {}. Sent {} notification status updates to the queue".format(
len(notifications))) service_id, len(notifications)))
def setup_commands(application): def setup_commands(application):