Skip jobs that are already reserved when removing from queue

ilijastuden · ilijastuden · commit a9fd485ecfff · 2021-10-01T20:21:11.000+02:00
diff --git a/src/Queue/MySqlQueue.php b/src/Queue/MySqlQueue.php
@@ -179,7 +179,7 @@ public function dequeue($job_id)
     public function dequeueByType(string $type, array $properties = null): void
     {
         $conditions = [
-            $this->connection->prepare('`type` = ?', $type),
+            $this->connection->prepare('`type` = ? AND `reservation_key` IS NULL', $type),
         ];
 
         if ($properties) {

Original file line number	Diff line number	Diff line change
`@@ -179,7 +179,7 @@ public function dequeue($job_id)`
`179`	`179`	`public function dequeueByType(string $type, array $properties = null): void`
`180`	`180`	`{`
`181`	`181`	`$conditions = [`
`182`		- $this->connection->prepare('`type` = ?', $type),
	`182`	+ $this->connection->prepare('`type` = ? AND `reservation_key` IS NULL', $type),
`183`	`183`	`];`
`184`	`184`
`185`	`185`	`if ($properties) {`