est_date to local_date, too

This commit is contained in:
stvnrlly
2022-11-21 12:05:23 -05:00
parent a7d747cc98
commit 7f5c3c785e

View File

@@ -291,20 +291,20 @@ def letter_raise_alert_if_no_ack_file_for_zip():
@notify_celery.task(name='save-daily-notification-processing-time') @notify_celery.task(name='save-daily-notification-processing-time')
@cronitor("save-daily-notification-processing-time") @cronitor("save-daily-notification-processing-time")
def save_daily_notification_processing_time(est_date=None): def save_daily_notification_processing_time(local_date=None):
# est_date is a string in the format of "YYYY-MM-DD" # local_date is a string in the format of "YYYY-MM-DD"
if est_date is None: if local_date is None:
# if a date is not provided, we run against yesterdays data # if a date is not provided, we run against yesterdays data
est_date = (datetime.utcnow() - timedelta(days=1)).date() local_date = (datetime.utcnow() - timedelta(days=1)).date()
else: else:
est_date = datetime.strptime(est_date, "%Y-%m-%d").date() local_date = datetime.strptime(local_date, "%Y-%m-%d").date()
start_time = get_local_midnight_in_utc(est_date) start_time = get_local_midnight_in_utc(local_date)
end_time = get_local_midnight_in_utc(est_date + timedelta(days=1)) end_time = get_local_midnight_in_utc(local_date + timedelta(days=1))
result = dao_get_notifications_processing_time_stats(start_time, end_time) result = dao_get_notifications_processing_time_stats(start_time, end_time)
insert_update_processing_time( insert_update_processing_time(
FactProcessingTime( FactProcessingTime(
local_date=est_date, local_date=local_date,
messages_total=result.messages_total, messages_total=result.messages_total,
messages_within_10_secs=result.messages_within_10_secs messages_within_10_secs=result.messages_within_10_secs
) )