Merge pull request #239 from sparks-baird/sgbaird-patch-6

paho mqtt v2.0.0
sparks-baird · Feb 12, 2024 · 96d4397 · 96d4397
2 parents 3a9e126 + 9dd400b
commit 96d4397
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/src/self_driving_lab_demo/utils/observe.py b/src/self_driving_lab_demo/utils/observe.py
@@ -1,6 +1,7 @@
 """Based on the following resource:
 https://www.steves-internet-guide.com/receiving-messages-mqtt-python-clientq=Queue() # noqa: E501
 """
+
 import ast
 import json
 import logging

diff --git a/tests/sdl_demo_light_test.py b/tests/sdl_demo_light_test.py
@@ -174,7 +174,9 @@ def test_bad_rgb_payload_values():
 
 
 def get_client():
-    client = paho.Client(protocol=paho.MQTTv5)  # create new instance
+    client = paho.Client(
+        paho.CallbackAPIVersion.VERSION1, protocol=paho.MQTTv5
+    )  # create new instance
     client.on_connect = on_connect
     client.on_message = on_message
 
@@ -210,7 +212,9 @@ def assert_error(session_id, experiment_id, client):
 
 
 def test_bad_json_payload():
-    client = paho.Client(protocol=paho.MQTTv5)  # create new instance
+    client = paho.Client(
+        paho.CallbackAPIVersion.VERSION1, protocol=paho.MQTTv5
+    )  # create new instance
     client.on_connect = on_connect
     client.on_message = on_message