diff --git a/django_q/monitor.py b/django_q/monitor.py index 4c4815b..37ea940 100644 --- a/django_q/monitor.py +++ b/django_q/monitor.py @@ -108,12 +108,12 @@ def save_task(task, broker: Broker): filters[Conf.SAVE_LIMIT_PER] = value with db.transaction.atomic(using=db.router.db_for_write(Success)): - last = Success.objects.filter(**filters).select_for_update().last() + list(Success.objects.filter(**filters).select_for_update()) if ( task["success"] and 0 < Conf.SAVE_LIMIT <= Success.objects.filter(**filters).count() ): - last.delete() + Success.objects.filter(**filters).last().delete() # check if this task has previous results try: