can't use select_for_update after removing the transaction block

d-flood · Dec 7, 2024 · 4598507 · 4598507
1 parent 1506a4c
commit 4598507
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/peasy_jobs/__about__.py b/src/peasy_jobs/__about__.py
@@ -1 +1 @@
-__version__ = "0.3.2"
+__version__ = "0.3.3"
diff --git a/src/peasy_jobs/peasy_jobs.py b/src/peasy_jobs/peasy_jobs.py
@@ -322,7 +322,7 @@ def run(self, *, exit_when_queue_empty: bool):
                                 self.running = False
                                 break
 
-                        jobs = PeasyJobQueue.objects.select_for_update().filter(status=PeasyJobQueue.ENQUEUED)
+                        jobs = PeasyJobQueue.objects.filter(status=PeasyJobQueue.ENQUEUED)
                         job_ids = list(jobs.values_list("pk", flat=True)[: self.concurrency])
                         if job_ids:
                             PeasyJobQueue.objects.filter(pk__in=job_ids).update(