Merge branch '4' into 5.0

symbiote · Dec 19, 2023 · 5bd3eeb · 5bd3eeb
2 parents ba75e28 + b03a83a
commit 5bd3eeb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Services/QueuedJobService.php b/src/Services/QueuedJobService.php
@@ -729,7 +729,8 @@ protected function grabMutex(QueuedJobDescriptor $jobDescriptor)
         try {
             // Start a transaction which will hold until we have a lock on this descriptor.
             DB::get_conn()->withTransaction(function () use ($descriptorId) {
-                $query = 'SELECT "ID" FROM "QueuedJobDescriptor" WHERE "ID" = %s AND "Worker" IS NULL FOR UPDATE';
+                $forUpdate = DB::getConfig()['type'] == 'SQLite3Database' ? '' : ' FOR UPDATE';
+                $query = 'SELECT "ID" FROM "QueuedJobDescriptor" WHERE "ID" = %s AND "Worker" IS NULL' . $forUpdate;
 
                 $row = DB::query(sprintf($query, Convert::raw2sql($descriptorId)))->record();