Merge pull request #253 from keboola/CFT-42-1761299120-snowflake-decommission-error

Author: zajca

src/Connection/Snowflake/Exception/AccountDecommissionedException.php

@@ -0,0 +1,11 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Keboola\TableBackendUtils\Connection\Snowflake\Exception;
+
+use Doctrine\DBAL\Exception\ServerException;
+
+final class AccountDecommissionedException extends ServerException
+{
+}

src/Connection/Snowflake/SnowflakeExceptionConverter.php

@@ -10,6 +10,7 @@
 use Doctrine\DBAL\Query;
 use Keboola\TableBackendUtils\Connection\Exception\ConnectionException;
 use Keboola\TableBackendUtils\Connection\Exception\DriverException as SnowflakeDriverException;
+use Keboola\TableBackendUtils\Connection\Snowflake\Exception\AccountDecommissionedException;
 use Keboola\TableBackendUtils\Connection\Snowflake\Exception\CannotAccessObjectException;
 use Keboola\TableBackendUtils\Connection\Snowflake\Exception\StringTooLongException;
 use Keboola\TableBackendUtils\Connection\Snowflake\Exception\WarehouseTimeoutReached;
@@ -35,6 +36,20 @@ public function convert(Exception $exception, ?Query $query): DriverException
             );
         }
 
+        $pattern = '/This account has been marked for decommission/';
+        if (preg_match($pattern, $exception->getMessage())) {
+            return new AccountDecommissionedException(
+                new SnowflakeDriverException(
+                    'Snowflake account is marked for decommission. ' .
+                    'Please contact your administrator or update the component configuration to use an active account.',
+                    null,
+                    $exception->getCode(),
+                    $exception,
+                ),
+                $query,
+            );
+        }
+
         $pattern = "/String \'([^\']*)\' is too long and would be truncated/";
         $matches = null;
         if ($exception->getCode() === self::CODE_STRING_TRUNCATE