diff --git a/roombapy/roomba.py b/roombapy/roomba.py index c6a7126..7843d1b 100644 --- a/roombapy/roomba.py +++ b/roombapy/roomba.py @@ -158,10 +158,11 @@ def periodic_connection(self) -> None: # only one connection thread at a time! if self.periodic_connection_running: return - self.periodic_connection_running = True while not self.stop_connection: try: - self._connect() + if not self.periodic_connection_running: + self._connect() + self.periodic_connection_running = True except RoombaConnectionError as error: self.periodic_connection_running = False self.on_disconnect(MQTT_ERROR_MESSAGES[7])