darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-01-30 14:31:57 -05:00
Code Issues Packages Projects Releases Wiki Activity

update log messages in delete task.

Browse Source 
less prose, clearer output. (hopefully)
This commit is contained in:
Leo Hemsted
2021-12-14 13:06:04 +00:00
parent 0dc0e184b9
commit 228d72dc8f
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
app/celery/nightly_tasks.py
View File

@@ -89,10 +89,8 @@ def delete_letter_notifications_older_than_retention():
def _delete_notifications_older_than_retention_by_type(notification_type):
current_app.logger.info(
'Deleting {} notifications for services with flexible data retention'.format(notification_type))
flexible_data_retention = fetch_service_data_retention_for_all_services_by_notification_type(notification_type)
for f in flexible_data_retention:
day_to_delete_backwards_from = get_london_midnight_in_utc(
convert_utc_to_bst(datetime.utcnow()).date() - timedelta(days=f.days_of_retention)
@@ -116,11 +114,6 @@ def _delete_notifications_older_than_retention_by_type(notification_type):
service_ids_to_purge = service_ids_that_have_sent_notifications_recently - service_ids_with_data_retention
current_app.logger.info('Deleting {} notifications for {} services without flexible data retention'.format(
notification_type,
len(service_ids_to_purge)
))
for service_id in service_ids_to_purge:
delete_notifications_for_service_and_type.apply_async(queue=QueueNames.REPORTING, kwargs={
'service_id': service_id,
@@ -128,6 +121,12 @@ def _delete_notifications_older_than_retention_by_type(notification_type):
'datetime_to_delete_before': seven_days_ago
})
current_app.logger.info(
f'delete-notifications-older-than-retention: triggered subtasks for notification_type {notification_type}: '
f'{len(service_ids_with_data_retention)} services with flexible data retention, '
f'{len(service_ids_to_purge)} services without flexible data retention'
)
@notify_celery.task(name='delete-notifications-for-service-and-type')
def delete_notifications_for_service_and_type(service_id, notification_type, datetime_to_delete_before):
@@ -139,8 +138,11 @@ def delete_notifications_for_service_and_type(service_id, notification_type, dat
)
end = datetime.utcnow()
current_app.logger.info(
f'Deleted {num_deleted} {notification_type} notifications for '
f'service id: {service_id} in {(end - start).seconds} seconds'
f'delete-notifications-for-service-and-type: '
f'service: {service_id}, '
f'notification_type: {notification_type}, '
f'count deleted: {num_deleted}, '
f'duration: {(end - start).seconds} seconds'
)