Fix missing argument in mqtt.Client

due to new breaking change in paho.mqtt library starting from v2.0 Co-authored-by: Petter Rasmussen 147414449+prasm313@users.noreply.github.com
equinor · Feb 16, 2024 · 2e32cf8 · 2e32cf8
1 parent 937721d
commit 2e32cf8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/isar/services/service_connections/mqtt/mqtt_client.py b/src/isar/services/service_connections/mqtt/mqtt_client.py
@@ -53,7 +53,7 @@ def __init__(self, mqtt_queue: Queue) -> None:
 
         self.port: int = settings.MQTT_PORT
 
-        self.client: Client = Client()
+        self.client: Client = Client(mqtt.CallbackAPIVersion.VERSION1)
 
         self.client.enable_logger(logger=self.logger)