Fix alter distributed (#295)

Co-authored-by: djklim87 <klim@manticoresearch.com>
manticoresoftware · May 20, 2024 · 1354c47 · 1354c47
1 parent a0a50fc
commit 1354c47
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/src/Plugin/AlterDistributedTable/Handler.php b/src/Plugin/AlterDistributedTable/Handler.php
@@ -40,13 +40,12 @@ public function run(): Task {
 		$taskFn = static function (Payload $payload, Client $manticoreClient): TaskResult {
 
 			$hasTable = false;
-			$allDistributedTables = array_column(
-				iterator_to_array($manticoreClient->getAllTables(['distributed'])),
-				0
-			);
 
-			foreach ($allDistributedTables as $table) {
-				if ($table === $payload->table) {
+			foreach (iterator_to_array($manticoreClient->getAllTables()) as $tableInfo) {
+				if ($tableInfo[0] === $payload->table) {
+					if ($tableInfo[1] !== 'distributed') {
+						throw ManticoreSearchResponseError::create("Table $payload->table should be distributed");
+					}
 					$hasTable = true;
 					break;
 				}