File tree Expand file tree Collapse file tree 2 files changed +5
-10
lines changed
src/databricks/sql/telemetry Expand file tree Collapse file tree 2 files changed +5
-10
lines changed Original file line number Diff line number Diff line change @@ -145,7 +145,7 @@ def get_extractor(obj):
145
145
TelemetryExtractor: A specialized extractor instance:
146
146
- CursorExtractor for Cursor objects
147
147
- ResultSetExtractor for ResultSet objects
148
- - TelemetryExtractor (base) for all other objects
148
+ - Throws an NotImplementedError for all other objects
149
149
"""
150
150
if obj .__class__ .__name__ == "Cursor" :
151
151
return CursorExtractor (obj )
Original file line number Diff line number Diff line change @@ -59,14 +59,6 @@ def make_dummy_result_set_from_initial_results(initial_results):
59
59
]
60
60
return rs
61
61
62
- @staticmethod
63
- def mock_thrift_backend_with_retry_policy ():
64
- mock_thrift_backend = Mock ()
65
- mock_retry_policy = Mock ()
66
- mock_retry_policy .history = []
67
- mock_thrift_backend .retry_policy = mock_retry_policy
68
- return mock_thrift_backend
69
-
70
62
@staticmethod
71
63
def make_dummy_result_set_from_batch_list (batch_list ):
72
64
batch_index = 0
@@ -87,7 +79,10 @@ def fetch_results(
87
79
88
80
return results , batch_index < len (batch_list )
89
81
90
- mock_thrift_backend = FetchTests .mock_thrift_backend_with_retry_policy ()
82
+ mock_thrift_backend = Mock ()
83
+ mock_retry_policy = Mock ()
84
+ mock_retry_policy .history = []
85
+ mock_thrift_backend .retry_policy = mock_retry_policy
91
86
mock_thrift_backend .fetch_results = fetch_results
92
87
num_cols = len (batch_list [0 ][0 ]) if batch_list and batch_list [0 ] else 0
93
88
You can’t perform that action at this time.
0 commit comments