From 3c4b745ae349dab1b66750ec02da1be143e1739a Mon Sep 17 00:00:00 2001 From: Igor Abdrakhimov Date: Wed, 12 Jul 2023 17:12:27 -0700 Subject: [PATCH] Fix code style --- test/test_mqtt.py | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/test/test_mqtt.py b/test/test_mqtt.py index 8397c6807..f444ca9dd 100644 --- a/test/test_mqtt.py +++ b/test/test_mqtt.py @@ -400,18 +400,18 @@ def test_connect_disconnect_with_callbacks_happy(self): test_tls_opts = TlsContextOptions.create_client_with_mtls_from_path(test_input_cert, test_input_key) test_tls = ClientTlsContext(test_tls_opts) - onConnectionSuccessFuture = Future() - onConnectionClosedFuture = Future() + on_connection_success_future = Future() + on_connection_closed_future = Future() def on_connection_success_callback(connection, callback_data: OnConnectionSuccessData): - onConnectionSuccessFuture.set_result( + on_connection_success_future.set_result( {'return_code': callback_data.return_code, "session_present": callback_data.session_present}) def on_connection_failure_callback(connection, callback_data: OnConnectionFailureData): pass def on_connection_closed_callback(connection, callback_data: OnConnectionClosedData): - onConnectionClosedFuture.set_result({}) + on_connection_closed_future.set_result({}) connection = self._create_connection( endpoint=test_input_endpoint, @@ -420,11 +420,11 @@ def on_connection_closed_callback(connection, callback_data: OnConnectionClosedD on_connection_failure_callback=on_connection_failure_callback, on_connection_closed_callback=on_connection_closed_callback) connection.connect().result(TIMEOUT) - successData = onConnectionSuccessFuture.result(TIMEOUT) - self.assertEqual(successData['return_code'], ConnectReturnCode.ACCEPTED) - self.assertEqual(successData['session_present'], False) + success_data = on_connection_success_future.result(TIMEOUT) + self.assertEqual(success_data['return_code'], ConnectReturnCode.ACCEPTED) + self.assertEqual(success_data['session_present'], False) connection.disconnect().result(TIMEOUT) - onConnectionClosedFuture.result(TIMEOUT) + on_connection_closed_future.result(TIMEOUT) def test_connect_disconnect_with_callbacks_unhappy(self): test_input_endpoint = _get_env_variable("AWS_TEST_MQTT311_IOT_CORE_HOST")