Update client.py

eclipse-paho · Mar 25, 2024 · 7a0d184 · 7a0d184
1 parent 0053dc1
commit 7a0d184
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/paho/mqtt/client.py b/src/paho/mqtt/client.py
@@ -4418,8 +4418,10 @@ def _handle_on_connect_fail(self) -> None:
                         MQTT_LOG_ERR, 'Caught exception in on_connect_fail: %s', err)
 
     def _thread_main(self) -> None:
-        self.loop_forever(retry_first_connection=True)
-        self._thread = None
+        try:
+            self.loop_forever(retry_first_connection=True)
+        finally:
+            self._thread = None
 
     def _reconnect_wait(self) -> None:
         # See reconnect_delay_set for details