diff --git a/src/backend/apps/notifications/services.py b/src/backend/apps/notifications/services.py index 9a18cd5..6432b43 100644 --- a/src/backend/apps/notifications/services.py +++ b/src/backend/apps/notifications/services.py @@ -335,12 +335,9 @@ def _send_smtp(config: dict[str, Any], payload: dict[str, Any]) -> None: def _pending_notifications_for_flush() -> QuerySet[NotificationLog]: - pending = ( - NotificationLog.objects.filter( - status=NotificationStatus.PENDING, - ) - .order_by("created_at") - ) + pending = NotificationLog.objects.filter( + status=NotificationStatus.PENDING, + ).order_by("created_at") if not connection.features.has_select_for_update: return pending if connection.features.has_select_for_update_skip_locked: