Skip to content

Commit 6afa037

Browse files
committed
TelemetryResponse, send_count
Signed-off-by: Sai Shree Pradhan <saishree.pradhan@databricks.com>
1 parent c74b0e5 commit 6afa037

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

src/databricks/sql/telemetry/models/endpoint_models.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,3 +36,4 @@ class TelemetryResponse(JsonSerializableMixin):
3636
errors: List[str]
3737
numSuccess: int
3838
numProtoSuccess: int
39+
numRealtimeSuccess: int

src/databricks/sql/telemetry/telemetry_client.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,9 @@ def _send_telemetry(self, events):
207207
headers=headers,
208208
timeout=900,
209209
)
210-
future.add_done_callback(self._telemetry_request_callback, sent_count)
210+
future.add_done_callback(
211+
lambda fut: self._telemetry_request_callback(fut, sent_count=sent_count)
212+
)
211213
except Exception as e:
212214
logger.debug("Failed to submit telemetry request: %s", e)
213215

@@ -223,7 +225,7 @@ def _telemetry_request_callback(self, future, sent_count: int):
223225
response.text,
224226
)
225227

226-
telemetry_response = TelemetryResponse.from_json(**response.json())
228+
telemetry_response = TelemetryResponse(**response.json())
227229

228230
logger.debug(
229231
"Pushed Telemetry logs with success count: %s, error count: %s",

0 commit comments

Comments
 (0)