Skip to content

Commit

Permalink
chore: revert mqtt client check
Browse files Browse the repository at this point in the history
  • Loading branch information
allenporter committed Jan 21, 2025
1 parent 8963f4b commit 590f347
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions roborock/cloud_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -77,8 +77,7 @@ def __init__(self, user_data: UserData, device_info: DeviceData, queue_timeout:
async def async_release(self) -> None:
"""Release the MQTT client."""
await super().async_release()
if self._mqtt_client:
await self.event_loop.run_in_executor(None, self._mqtt_client.loop_stop)
await self.event_loop.run_in_executor(None, self._mqtt_client.loop_stop)

def _mqtt_on_connect(self, *args, **kwargs):
_, __, ___, rc, ____ = args
Expand Down

0 comments on commit 590f347

Please sign in to comment.