fix: Make thread not global

humbertogontijo · Oct 3, 2023 · f13b9bd · f13b9bd
1 parent 13220a5
commit f13b9bd
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/roborock/cloud_api.py b/roborock/cloud_api.py
@@ -3,7 +3,6 @@
 import asyncio
 import base64
 import logging
-import threading
 import uuid
 from asyncio import Lock, Task
 from typing import Any
@@ -26,9 +25,6 @@
 
 
 class RoborockMqttClient(RoborockClient, mqtt.Client):
-    _thread: threading.Thread
-    _client_id: str
-
     def __init__(self, user_data: UserData, device_info: DeviceData, queue_timeout: int = 10) -> None:
         rriot = user_data.rriot
         if rriot is None:
@@ -54,6 +50,7 @@ def __init__(self, user_data: UserData, device_info: DeviceData, queue_timeout:
         self._waiting_queue: dict[int, RoborockFuture] = {}
         self._mutex = Lock()
         self.update_client_id()
+        self._thread = None
 
     def on_connect(self, *args, **kwargs):
         _, __, ___, rc, ____ = args