File tree Expand file tree Collapse file tree 2 files changed +15
-1
lines changed Expand file tree Collapse file tree 2 files changed +15
-1
lines changed Original file line number Diff line number Diff line change 9
9
10
10
from dbt .adapters .base import Credentials
11
11
from dbt .adapters .sql import SQLConnectionManager
12
+ from dbt .contracts .connection import AdapterResponse
12
13
from dbt .contracts .connection import Connection
13
14
from dbt .exceptions import (
14
15
DatabaseException ,
@@ -114,6 +115,19 @@ def open(cls, connection):
114
115
def get_status (cls , cursor : sqlite3 .Cursor ):
115
116
return f"OK" # {cursor.rowcount}"
116
117
118
+
119
+ def get_response (cls , cursor ) -> AdapterResponse :
120
+ """
121
+ new to support dbt 0.19: this method replaces get_response
122
+ """
123
+ message = 'OK'
124
+ rows = cursor .rowcount
125
+ return AdapterResponse (
126
+ _message = message ,
127
+ rows_affected = rows
128
+ )
129
+
130
+
117
131
def cancel (self , connection ):
118
132
""" cancel ongoing queries """
119
133
Original file line number Diff line number Diff line change 28
28
]
29
29
},
30
30
install_requires = [
31
- "dbt-core~=0.18 .0" ,
31
+ "dbt-core~=0.19 .0" ,
32
32
],
33
33
classifiers = [
34
34
'Development Status :: 3 - Alpha' ,
You can’t perform that action at this time.
0 commit comments