|
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