darkhelm/notifications-api
1
0
Fork 0
mirror of https://github.com/GSA/notifications-api.git synced 2026-08-19 05:58:53 -04:00
Code Issues Packages Projects Releases Wiki Activity

Standardise logs for status aggregation tasks

Browse Source 
This will make it easier to parallelise by service later on.
This commit is contained in:
Ben Thorner
2022-01-11 16:46:45 +00:00
parent 4feed950c4
commit d772ae6b46
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
app/celery/reporting_tasks.py
View File

@@ -103,7 +103,7 @@ def create_nightly_notification_status():
) )
current_app.logger.info( current_app.logger.info(
f"create-nightly-notification-status-for-day task created " f"create-nightly-notification-status-for-day task created "
f"for type {notification_type} for {process_day}" f"for {notification_type} and {process_day}"
) )
@@ -111,7 +111,8 @@ def create_nightly_notification_status():
def create_nightly_notification_status_for_day(process_day, notification_type): def create_nightly_notification_status_for_day(process_day, notification_type):
process_day = datetime.strptime(process_day, "%Y-%m-%d").date() process_day = datetime.strptime(process_day, "%Y-%m-%d").date()
current_app.logger.info( current_app.logger.info(
f'create-nightly-notification-status-for-day task for {process_day} type {notification_type}: started' f'create-nightly-notification-status-for-day task started '
f'for {notification_type} and {process_day}'
) )
for (service_id,) in db.session.query(Service.id): for (service_id,) in db.session.query(Service.id):
@@ -124,7 +125,8 @@ def create_nightly_notification_status_for_day(process_day, notification_type):
end = datetime.utcnow() end = datetime.utcnow()
current_app.logger.info( current_app.logger.info(
f'create-nightly-notification-status-for-day task for {process_day} type {notification_type}: ' f'create-nightly-notification-status-for-day task fetch '
f'for {process_day} and {notification_type}: '
f'data fetched in {(end - start).seconds} seconds' f'data fetched in {(end - start).seconds} seconds'
) )
@@ -136,6 +138,7 @@ def create_nightly_notification_status_for_day(process_day, notification_type):
) )
current_app.logger.info( current_app.logger.info(
f'create-nightly-notification-status-for-day task for {process_day} type {notification_type}: ' f'create-nightly-notification-status-for-day task finished '
f'task complete - {len(transit_data)} rows updated' f'for {process_day} and {notification_type}: '
f'{len(transit_data)} rows updated'
) )