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

Fix max attempts for value 1 (#185)

Browse Source
This commit is contained in:
Stan Triepels
2024-05-06 17:28:27 +02:00
committed by GitHub
parent 5e4aa65f62
commit 1d1d0a9aa5
1 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/monitor.py
+15 -14
View File
@@ -117,25 +117,19 @@ def save_task(task, broker: Broker):
# check if this task has previous results
try:
existing_task = Task.objects.get(id=task["id"], name=task["name"])
task_obj = Task.objects.get(id=task["id"], name=task["name"])
# only update the result if it hasn't succeeded yet
if not existing_task.success:
existing_task.stopped = task["stopped"]
existing_task.result = task["result"]
existing_task.success = task["success"]
existing_task.attempt_count = existing_task.attempt_count + 1
existing_task.save()
if (
Conf.MAX_ATTEMPTS > 0
and existing_task.attempt_count >= Conf.MAX_ATTEMPTS
):
broker.acknowledge(task["ack_id"])
if not task_obj.success:
task_obj.stopped = task["stopped"]
task_obj.result = task["result"]
task_obj.success = task["success"]
task_obj.attempt_count = task_obj.attempt_count + 1
task_obj.save()
except Task.DoesNotExist:
# convert func to string
func = get_func_repr(task["func"])
Task.objects.create(
task_obj = Task.objects.create(
id=task["id"],
name=task["name"],
func=func,
@@ -150,6 +144,13 @@ def save_task(task, broker: Broker):
success=task["success"],
attempt_count=1,
)
if (
Conf.MAX_ATTEMPTS > 0
and task_obj.attempt_count >= Conf.MAX_ATTEMPTS
):
broker.acknowledge(task["ack_id"])
except Exception:
logger.exception("Could not save task result")