diff --git a/src/Services/QueuedJobService.php b/src/Services/QueuedJobService.php index b2635d6..023567f 100644 --- 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)))->first();