Skip to content

Commit

Permalink
Migrate to use system tables
Browse files Browse the repository at this point in the history
  • Loading branch information
donhardman committed Jan 10, 2025
1 parent 5035c02 commit 1406ab2
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion src/Plugin/Sharding/Queue.php
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`node` string,
`query` string,
`wait_for_id` bigint,
Expand Down
2 changes: 1 addition & 1 deletion src/Plugin/Sharding/State.php
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`key` string,
`value` json,
`updated_at` timestamp
Expand Down
2 changes: 1 addition & 1 deletion src/Plugin/Sharding/Table.php
Original file line number Diff line number Diff line change
Expand Up @@ -710,7 +710,7 @@ public function setup(): void {
'Trying to initialize while already initialized.'
);
}
$query = "CREATE TABLE `{$this->table}` (
$query = "CREATE TABLE {$this->table} (
`cluster` string,
`node` string,
`table` string,
Expand Down

0 comments on commit 1406ab2

Please sign in to comment.