Skip to content

Commit 8f5e363

Browse files
committed
fix(sharding): correct table name usage in dequeue query
1 parent f7fa651 commit 8f5e363

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/Plugin/Sharding/Queue.php

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -232,9 +232,8 @@ protected function attemptToUpdateStatus(array $query, string $status, int $dura
232232
*/
233233
protected function dequeue(Node $node): Vector {
234234
$maxTries = static::MAX_TRIES;
235-
$table = $this->cluster->getSystemTableName($this->table);
236235
$query = "
237-
SELECT * FROM {$table}
236+
SELECT * FROM {$this->table}
238237
WHERE
239238
`node` = '{$node->id}'
240239
AND

0 commit comments

Comments
 (0)