| 
5 | 5 | import os.path  | 
6 | 6 | import sqlite3  | 
7 | 7 | from socket import gethostname  | 
8 |  | -from typing import Optional, Tuple, Any, Dict, List  | 
 | 8 | +from typing import Optional, Tuple, Any, Dict, List, Union  | 
9 | 9 | 
 
  | 
10 |  | - | 
11 |  | -from dbt.adapters.base import Credentials  | 
 | 10 | +from dbt.adapters.contracts.connection import Credentials  | 
12 | 11 | from dbt.adapters.sql import SQLConnectionManager  | 
13 |  | -from dbt.contracts.connection import AdapterResponse  | 
14 |  | -from dbt.contracts.connection import Connection  | 
15 |  | -from dbt.exceptions import (  | 
 | 12 | +from dbt.adapters.contracts.connection import AdapterResponse  | 
 | 13 | +from dbt.adapters.contracts.connection import Connection  | 
 | 14 | +from dbt.adapters.events.logging import AdapterLogger  | 
 | 15 | +from dbt.adapters.exceptions.connection import FailedToConnectError  | 
 | 16 | +from dbt_common.exceptions import (  | 
16 | 17 |     DbtDatabaseError,  | 
17 |  | -    FailedToConnectError,  | 
18 | 18 |     DbtRuntimeError  | 
19 | 19 | )  | 
20 |  | -from dbt.logger import GLOBAL_LOGGER as logger  | 
 | 20 | + | 
 | 21 | +logger = AdapterLogger("SQLite")  | 
21 | 22 | 
 
  | 
22 | 23 | 
 
  | 
23 | 24 | @dataclass  | 
@@ -175,3 +176,7 @@ def add_query(  | 
175 | 176 | 
 
  | 
176 | 177 |         return super().add_query(sql=sql, auto_begin=auto_begin, bindings=bindings, abridge_sql_log=abridge_sql_log)  | 
177 | 178 | 
 
  | 
 | 179 | +    @classmethod  | 
 | 180 | +    def data_type_code_to_name(cls, type_code: Union[int, str]) -> str:  | 
 | 181 | +        # TODO: figure out how to implement this  | 
 | 182 | +        return "UNKNOWN"  | 
0 commit comments