[18.0][IMP] queue_job: take weaker locks

queue_job/controllers/main.py

@@ -41,7 +41,7 @@ def _acquire_job(cls, env: api.Environment, job_uuid: str) -> Job | None:
         """
         env.cr.execute(
             "SELECT uuid FROM queue_job WHERE uuid=%s AND state=%s "
-            "FOR UPDATE SKIP LOCKED",
+            "FOR NO KEY UPDATE SKIP LOCKED",
             (job_uuid, ENQUEUED),
         )
         if not env.cr.fetchone():

queue_job/job.py

@@ -263,7 +263,7 @@ def lock(self) -> bool:
                         uuid = %s
                         AND state = %s
                 )
-            FOR UPDATE SKIP LOCKED;
+            FOR NO KEY UPDATE SKIP LOCKED;
         """,
             [self.uuid, STARTED],
         )

queue_job/jobrunner/runner.py

@@ -367,7 +367,7 @@ def _query_requeue_dead_jobs(self):
                             queue_job_lock
                         WHERE
                             queue_job_lock.queue_job_id = queue_job.id
-                        FOR UPDATE SKIP LOCKED
+                        FOR NO KEY UPDATE SKIP LOCKED
                     )
                     OR NOT EXISTS (
                         SELECT

test_queue_job/tests/test_requeue_dead_job.py

@@ -35,7 +35,7 @@ def get_locks(self, uuid, cr=None):
                     WHERE
                         uuid = %s
                 )
-            FOR UPDATE SKIP LOCKED
+            FOR NO KEY UPDATE SKIP LOCKED
             """,
             [uuid],
         )