diff --git a/frigate/comms/mqtt.py b/frigate/comms/mqtt.py
index 718376aa5..01604abb5 100644
--- a/frigate/comms/mqtt.py
+++ b/frigate/comms/mqtt.py
@@ -24,7 +24,6 @@ class MqttClient(Communicator):
         self._reconnect_thread: Optional[threading.Thread] = None
         self._reconnect_delay = 10  # Retry every 10 seconds
         self._stop_reconnect: bool = False
-        self._cleanup_in_progress: bool = False
 
     def subscribe(self, receiver: Callable[[str, str], None]) -> None:
         """Wrapper for allowing dispatcher to subscribe."""
@@ -240,16 +239,12 @@ class MqttClient(Communicator):
             f"MQTT disconnected - reason: '{reason_name}', code: {reason_value}, type: {type(reason_code)}"
         )
 
-        # Don't attempt reconnection if we're stopping, cleaning up, or if it was a clean disconnect
+        # Don't attempt reconnection if we're stopping or if it was a clean disconnect
         if self._stop_reconnect:
             logger.error("MQTT not reconnecting - stop flag set")
             return
 
-        if self._cleanup_in_progress:
-            logger.error("MQTT not reconnecting - cleanup in progress")
-            return
-
-        if reason_code == 0:
+        if reason_value == 0:
             logger.error("MQTT not reconnecting - clean disconnect (code 0)")
             return
 
@@ -384,12 +379,9 @@ class MqttClient(Communicator):
                 # Clean up old client if it exists
                 if self.client is not None:
                     try:
-                        self._cleanup_in_progress = True
                         self.client.disconnect()
                         self.client.loop_stop()
-                        self._cleanup_in_progress = False
                     except Exception:
-                        self._cleanup_in_progress = False
                         pass  # Ignore cleanup errors
 
                 # Create completely fresh client and attempt connection