DRF_Template/backend/notifications/tasks.py

12 lines
413 B
Python

from celery import shared_task
from django.utils import timezone
from notifications.models import Notification
@shared_task
def cleanup_notifications():
# Calculate the date 3 days ago
three_days_ago = timezone.now() - timezone.timedelta(days=3)
# Delete notifications that are older than 3 days and dismissed
Notification.objects.filter(dismissed=True, timestamp__lte=three_days_ago).delete()