fix: add exit() when disconnected

arenaxr · Aug 8, 2024 · 28944e2 · 28944e2
1 parent ca9b71a
commit 28944e2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/arena/arena_mqtt.py b/arena/arena_mqtt.py
@@ -264,6 +264,7 @@ def on_connect(self, client, userdata, flags, rc):
 
         else:
             print(f"Connection error! Result code={rc}")
+            os._exit(1)
 
     def on_message(self, client, userdata, msg):
         # ignore own messages
@@ -281,6 +282,8 @@ def on_disconnect(self, client, userdata, rc):
         else:
             print(f"Disconnected! Result code={rc}.")
 
+        os._exit(rc)
+
     def disconnect(self):
         """Disconnects Paho MQTT client"""
         if self.end_program_callback: