new exception names

Author: codeforkjeff

dbt/adapters/sqlite/connections.py

@@ -12,9 +12,9 @@
 from dbt.contracts.connection import AdapterResponse
 from dbt.contracts.connection import Connection
 from dbt.exceptions import (
-    DatabaseException,
-    FailedToConnectException,
-    RuntimeException
+    DbtDatabaseError,
+    FailedToConnectError,
+    DbtRuntimeError
 )
 from dbt.logger import GLOBAL_LOGGER as logger
 
@@ -66,7 +66,7 @@ def open(cls, connection: Connection):
                 handle: sqlite3.Connection = sqlite3.connect(schemas_and_paths['main'])
                 attached.append(schemas_and_paths['main'])
             else:
-                raise FailedToConnectException("at least one schema must be called 'main'")
+                raise FailedToConnectError("at least one schema must be called 'main'")
 
             if len(credentials.extensions) > 0:
                 handle.enable_load_extension(True)
@@ -92,7 +92,7 @@ def open(cls, connection: Connection):
                     if schema not in attached:
                         cursor.execute(f"attach '{path}' as '{schema}'")
                     else:
-                        raise FailedToConnectException(
+                        raise FailedToConnectError(
                             f"found {path} while scanning schema_directory, but cannot attach it as '{schema}' " +
                             f"because that schema name is already defined in schemas_and_paths. " +
                             f"fix your ~/.dbt/profiles.yml file")
@@ -112,7 +112,7 @@ def open(cls, connection: Connection):
             connection.handle = None
             connection.state = "fail"
 
-            raise FailedToConnectException(str(e))
+            raise FailedToConnectError(str(e))
         except Exception as e:
             print(f"Unknown error opening SQLite connection: {e}")
             raise e
@@ -151,12 +151,12 @@ def exception_handler(self, sql: str):
         except sqlite3.DatabaseError as e:
             self.release()
             logger.debug("sqlite3 error: {}".format(str(e)))
-            raise DatabaseException(str(e))
+            raise DbtDatabaseError(str(e))
         except Exception as e:
             logger.debug("Error running SQL: {}".format(sql))
             logger.debug("Rolling back transaction.")
             self.release()
-            raise RuntimeException(str(e))
+            raise DbtRuntimeError(str(e))
 
     def add_query(
         self,

dbt/adapters/sqlite/impl.py

@@ -12,7 +12,7 @@
 from dbt.adapters.sqlite import SQLiteConnectionManager
 from dbt.adapters.sqlite.relation import SQLiteRelation
 from dbt.contracts.graph.manifest import Manifest
-from dbt.exceptions import NotImplementedException
+from dbt.exceptions import NotImplementedError
 
 
 class SQLiteAdapter(SQLAdapter):
@@ -93,7 +93,7 @@ def rename_relation(self, from_relation, to_relation):
             self.connections.execute(new_definition)
 
         else:
-            raise NotImplementedException(
+            raise NotImplementedError(
                 f"I don't know how to rename this type of relation: {from_relation.type}," +
                 f" from: {from_relation}, to: {to_relation}")