fix predis hdel

michalsn · michalsn · commit 93e4c5ffedaa · 2023-12-17T09:53:36.000+01:00
diff --git a/src/Handlers/PredisHandler.php b/src/Handlers/PredisHandler.php
@@ -94,7 +94,7 @@ public function later(QueueJob $queueJob, int $seconds): bool
         $queueJob->available_at = Time::now()->addSeconds($seconds)->timestamp;
 
         if ($result = $this->predis->zadd("queues:{$queueJob->queue}:{$queueJob->priority}", [json_encode($queueJob) => $queueJob->available_at->timestamp])) {
-            $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);
+            $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);
         }
 
         return $result > 0;
@@ -109,7 +109,7 @@ public function failed(QueueJob $queueJob, Throwable $err, bool $keepJob): bool
             $this->logFailed($queueJob, $err);
         }
 
-        return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);
+        return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);
     }
 
     /**
@@ -122,7 +122,7 @@ public function done(QueueJob $queueJob, bool $keepJob): bool
             $this->predis->lpush("queues:{$queueJob->queue}::done", [json_encode($queueJob)]);
         }
 
-        return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);
+        return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ public function later(QueueJob $queueJob, int $seconds): bool`
`94`	`94`	`$queueJob->available_at = Time::now()->addSeconds($seconds)->timestamp;`
`95`	`95`
`96`	`96`	`if ($result = $this->predis->zadd("queues:{$queueJob->queue}:{$queueJob->priority}", [json_encode($queueJob) => $queueJob->available_at->timestamp])) {`
`97`		`- $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);`
	`97`	`+ $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);`
`98`	`98`	`}`
`99`	`99`
`100`	`100`	`return $result > 0;`
`@@ -109,7 +109,7 @@ public function failed(QueueJob $queueJob, Throwable $err, bool $keepJob): bool`
`109`	`109`	`$this->logFailed($queueJob, $err);`
`110`	`110`	`}`
`111`	`111`
`112`		`- return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);`
	`112`	`+ return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);`
`113`	`113`	`}`
`114`	`114`
`115`	`115`	`/**`
`@@ -122,7 +122,7 @@ public function done(QueueJob $queueJob, bool $keepJob): bool`
`122`	`122`	`$this->predis->lpush("queues:{$queueJob->queue}::done", [json_encode($queueJob)]);`
`123`	`123`	`}`
`124`	`124`
`125`		`- return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", $queueJob->id);`
	`125`	`+ return (bool) $this->predis->hdel("queues:{$queueJob->queue}::reserved", [$queueJob->id]);`
`126`	`126`	`}`
`127`	`127`
`128`	`128`	`/**`