fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-05 22:28:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fixes #225 (#552)

Browse Source
This commit is contained in:
Kenny Heinonen
2021-05-07 17:26:41 +02:00
committed by GitHub
parent 57ae1dc4dc
commit ad77ad7512
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+4 -2
View File
@@ -476,8 +476,10 @@ def save_task(task, broker: Broker):
# SAVE LIMIT > 0: Prune database, SAVE_LIMIT 0: No pruning # SAVE LIMIT > 0: Prune database, SAVE_LIMIT 0: No pruning
close_old_django_connections() close_old_django_connections()
try: try:
if task["success"] and 0 < Conf.SAVE_LIMIT <= Success.objects.count(): with db.transaction.atomic():
Success.objects.last().delete() last = Success.objects.select_for_update().last()
if task["success"] and 0 < Conf.SAVE_LIMIT <= Success.objects.count():
last.delete()
# check if this task has previous results # check if this task has previous results
if Task.objects.filter(id=task["id"], name=task["name"]).exists(): if Task.objects.filter(id=task["id"], name=task["name"]).exists():
existing_task = Task.objects.get(id=task["id"], name=task["name"]) existing_task = Task.objects.get(id=task["id"], name=task["name"])