Merge pull request #42 from keboola/ondra-checker-different-warehouse

use different warehouse in checker
keboola · Oct 25, 2024 · 281925e · 281925e
2 parents 3b06443 + 1d41472
commit 281925e
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/src/MigrationChecker.php b/src/MigrationChecker.php
@@ -28,10 +28,17 @@ public function postMigrationCheckStructure(Role $mainRoleWithGrants): void
         $warehouses = $mainRoleWithGrants->getAssignedGrants()->getWarehouseGrants();
 
         assert(count($warehouses) > 0);
-        $useWarehouse = sprintf('USE WAREHOUSE %s', Helper::quoteIdentifier(current($warehouses)->getName()));
+        $useWarehouseSource = sprintf(
+            'USE WAREHOUSE %s',
+            Helper::quoteIdentifier($this->config->getSourceSnowflakeWarehouse()),
+        );
+        $useWarehouseDestination = sprintf(
+            'USE WAREHOUSE %s',
+            Helper::quoteIdentifier(current($warehouses)->getName()),
+        );
 
-        $this->sourceConnection->query($useWarehouse);
-        $this->destinationConnection->query($useWarehouse);
+        $this->sourceConnection->query($useWarehouseSource);
+        $this->destinationConnection->query($useWarehouseDestination);
 
         foreach ($this->databases as $database) {
             $this->logger->info(sprintf('Checking database %s', $database));