diff --git a/app/dao/notifications_dao.py b/app/dao/notifications_dao.py index 80cba3eb9..fac12f5af 100644 --- a/app/dao/notifications_dao.py +++ b/app/dao/notifications_dao.py @@ -295,13 +295,14 @@ def dao_delete_notifications_and_history_by_id(notification_id): def dao_timeout_notifications(timeout_period_in_seconds): # update all notifications that are older that the timeout_period_in_seconds # with a status of created|sending|pending + update_at = datetime.utcnow() updated = db.session.query(Notification). \ filter(Notification.created_at < (datetime.utcnow() - timedelta(seconds=timeout_period_in_seconds))). \ filter(Notification.status.in_([NOTIFICATION_CREATED, NOTIFICATION_SENDING, NOTIFICATION_PENDING])). \ - update({'status': NOTIFICATION_TEMPORARY_FAILURE}, synchronize_session=False) + update({'status': NOTIFICATION_TEMPORARY_FAILURE, 'updated_at': update_at}, synchronize_session=False) db.session.query(NotificationHistory). \ filter(NotificationHistory.created_at < (datetime.utcnow() - timedelta(seconds=timeout_period_in_seconds))). \ filter(NotificationHistory.status.in_([NOTIFICATION_CREATED, NOTIFICATION_SENDING, NOTIFICATION_PENDING])). \ - update({'status': NOTIFICATION_TEMPORARY_FAILURE}, synchronize_session=False) + update({'status': NOTIFICATION_TEMPORARY_FAILURE, 'updated_at': update_at}, synchronize_session=False) db.session.commit() return updated