test: set queue timeout of 10

Author: allenporter

tests/conftest.py

@@ -22,6 +22,7 @@
 
 # Used by fixtures to handle incoming requests and prepare responses
 RequestHandler = Callable[[bytes], bytes | None]
+QUEUE_TIMEOUT = 10
 
 
 class FakeSocketHandler:
@@ -145,7 +146,7 @@ async def mqtt_client(mock_create_connection: None, mock_select: None) -> AsyncG
         device=home_data.devices[0],
         model=home_data.products[0].model,
     )
-    client = RoborockMqttClientV1(user_data, device_info)
+    client = RoborockMqttClientV1(user_data, device_info, queue_timeout=QUEUE_TIMEOUT)
     try:
         yield client
     finally:
@@ -239,7 +240,7 @@ async def local_client_fixture(mock_create_local_connection: None) -> AsyncGener
         model=home_data.products[0].model,
         host=TEST_LOCAL_API_HOST,
     )
-    client = RoborockLocalClientV1(device_info)
+    yield RoborockLocalClientV1(device_info, queue_timeout=QUEUE_TIMEOUT)
     try:
         yield client
     finally:

tests/test_a01_api.py

@@ -33,6 +33,7 @@
 )
 
 from . import mqtt_packet
+from .conftest import QUEUE_TIMEOUT
 
 
 @pytest.fixture(name="a01_mqtt_client")
@@ -51,7 +52,7 @@ async def a01_mqtt_client_fixture(
         device=home_data.devices[0],
         model=home_data.products[0].model,
     )
-    client = RoborockMqttClientA01(user_data, device_info, RoborockCategory.WASHING_MACHINE)
+    client = RoborockMqttClientA01(user_data, device_info, RoborockCategory.WASHING_MACHINE, queue_timeout=QUEUE_TIMEOUT)
     try:
         yield client
     finally:

tests/test_api.py

@@ -33,6 +33,7 @@
 )
 
 from . import mqtt_packet
+from .conftest import QUEUE_TIMEOUT
 
 
 def test_can_create_prepared_request():