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

fix: Oracle ORM backend compatibility #180 (#186)

Browse Source
This commit is contained in:
jv3ga
2024-08-13 04:40:54 +02:00
committed by GitHub
parent cb253357fb
commit 5015d8ee4d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/monitor.py
+2 -2
View File
@@ -108,12 +108,12 @@ def save_task(task, broker: Broker):
filters[Conf.SAVE_LIMIT_PER] = value filters[Conf.SAVE_LIMIT_PER] = value
with db.transaction.atomic(using=db.router.db_for_write(Success)): 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 ( if (
task["success"] task["success"]
and 0 < Conf.SAVE_LIMIT <= Success.objects.filter(**filters).count() 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 # check if this task has previous results
try: try: