@@ -290,10 +290,10 @@ def test_factory_shutdown_flow(self):
290290 assert TelemetryClientFactory ._initialized is False
291291 assert TelemetryClientFactory ._executor is None
292292
293+ @patch ("databricks.sql.telemetry.telemetry_client.TelemetryClient.export_failure_log" )
293294 @patch ("databricks.sql.client.Session" )
294- @patch ("databricks.sql.telemetry.telemetry_client.TelemetryClient._send_telemetry" )
295295 def test_connection_failure_sends_correct_telemetry_payload (
296- self , mock_send_telemetry , mock_session
296+ self , mock_session , mock_export_failure_log
297297 ):
298298 """
299299 Verify that a connection failure constructs and sends the correct
@@ -309,17 +309,7 @@ def test_connection_failure_sends_correct_telemetry_payload(
309309 except Exception as e :
310310 assert str (e ) == error_message
311311
312- mock_send_telemetry .assert_called_once ()
313-
314- call_arguments = mock_send_telemetry .call_args .args
315- sent_events = call_arguments [0 ]
316-
317- assert len (sent_events ) == 1
318- telemetry_log = sent_events [0 ]
319-
320- assert telemetry_log .entry .sql_driver_log is not None
321-
322- error_info = telemetry_log .entry .sql_driver_log .error_info
323- assert error_info is not None
324- assert error_info .error_name == "Exception"
325- assert error_info .stack_trace == error_message
312+ mock_export_failure_log .assert_called_once ()
313+ call_arguments = mock_export_failure_log .call_args
314+ assert call_arguments [0 ][0 ] == "Exception"
315+ assert call_arguments [0 ][1 ] == error_message
0 commit comments