|
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