Add scheduled field to Notification model and update digest email tasks

Author: Ostap-Zherebetskyi

notifications/tasks.py

@@ -314,6 +314,8 @@ def send_users_digest_email(dry_run=False):
             user_id = group['user_id']
             notification_ids = [msg['notification_id'] for msg in group['info']]
             if not dry_run:
+                notifications_qs = Notification.objects.filter(id__in=notification_ids)
+                notifications_qs.update(scheduled=True)
                 send_user_email_task.delay(user_id, notification_ids)
 
 @celery_app.task(name='notifications.tasks.send_moderators_digest_email')
@@ -334,6 +336,8 @@ def send_moderators_digest_email(dry_run=False):
             provider_content_type_id = group['provider_content_type_id']
             notification_ids = [msg['notification_id'] for msg in group['info']]
             if not dry_run:
+                notifications_qs = Notification.objects.filter(id__in=notification_ids)
+                notifications_qs.update(scheduled=True)
                 send_moderator_email_task.delay(user_id, notification_ids, provider_content_type_id, provider_id)
 
 def get_moderators_emails(message_freq: str):
@@ -358,6 +362,7 @@ def get_moderators_emails(message_freq: str):
         INNER JOIN osf_notificationtype AS nt ON ns.notification_type_id = nt.id
         LEFT JOIN osf_guid ON ns.user_id = osf_guid.object_id
         WHERE n.sent IS NULL
+            AND n.scheduled = FALSE
             AND ns.message_frequency = %s
             AND nt.name IN (%s, %s)
             AND nt.name NOT IN (%s, %s, %s)
@@ -401,6 +406,7 @@ def get_users_emails(message_freq):
         INNER JOIN osf_notificationtype AS nt ON ns.notification_type_id = nt.id
         LEFT JOIN osf_guid ON ns.user_id = osf_guid.object_id
         WHERE n.sent IS NULL
+            AND n.scheduled = FALSE
             AND ns.message_frequency = %s
             AND nt.name NOT IN (%s, %s, %s, %s, %s)
             AND osf_guid.content_type_id = (

osf/migrations/0040_notification_scheduled.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.2.26 on 2026-06-04 11:52
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('osf', '0039_merge_20260427_1359'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='notification',
+            name='scheduled',
+            field=models.BooleanField(default=False),
+        ),
+    ]

osf/models/notification.py

@@ -18,6 +18,7 @@ class Notification(models.Model):
     sent = models.DateTimeField(null=True, blank=True)
     created = models.DateTimeField(auto_now_add=True)
     fake_sent = models.BooleanField(default=False)
+    scheduled = models.BooleanField(default=False)
 
     def send(
             self,