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 @@ def mqtt_client(mock_create_connection: None, mock_select: None) -> Generator[Ro
         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)
     yield client
     # Clean up any resources after the test
 
@@ -233,4 +234,4 @@ def local_client_fixture(mock_create_local_connection: None) -> Generator[Roboro
         model=home_data.products[0].model,
         host=TEST_LOCAL_API_HOST,
     )
-    yield RoborockLocalClientV1(device_info)
+    yield RoborockLocalClientV1(device_info, queue_timeout=QUEUE_TIMEOUT)

tests/test_a01_api.py

@@ -33,6 +33,7 @@
 )
 
 from . import mqtt_packet
+from .conftest import QUEUE_TIMEOUT
 
 
 @pytest.fixture(name="a01_mqtt_client")
@@ -49,7 +50,7 @@ async def a01_mqtt_client_fixture(mock_create_connection: None, mock_select: Non
         device=home_data.devices[0],
         model=home_data.products[0].model,
     )
-    return RoborockMqttClientA01(user_data, device_info, RoborockCategory.WASHING_MACHINE)
+    return RoborockMqttClientA01(user_data, device_info, RoborockCategory.WASHING_MACHINE, queue_timeout=QUEUE_TIMEOUT)
 
 
 @pytest.fixture(name="connected_a01_mqtt_client")

tests/test_api.py

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