From d6a0f9b5a004d8b8ca865204db1d7b37b6d219fe Mon Sep 17 00:00:00 2001 From: Jan Bouwhuis Date: Mon, 30 Oct 2023 06:02:03 +0100 Subject: [PATCH] Give mqtt test more time to process subscriptions (#103006) --- tests/components/mqtt/test_discovery.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/tests/components/mqtt/test_discovery.py b/tests/components/mqtt/test_discovery.py index 863a79fce70..ed01b70e660 100644 --- a/tests/components/mqtt/test_discovery.py +++ b/tests/components/mqtt/test_discovery.py @@ -1523,18 +1523,20 @@ async def test_mqtt_integration_discovery_subscribe_unsubscribe( return self.async_abort(reason="already_configured") with patch.dict(config_entries.HANDLERS, {"comp": TestFlow}): - await asyncio.sleep(0.1) + await asyncio.sleep(0) assert ("comp/discovery/#", 0) in help_all_subscribe_calls(mqtt_client_mock) assert not mqtt_client_mock.unsubscribe.called async_fire_mqtt_message(hass, "comp/discovery/bla/config", "") - await asyncio.sleep(0.1) + await asyncio.sleep(0) + await hass.async_block_till_done() await hass.async_block_till_done() mqtt_client_mock.unsubscribe.assert_called_once_with(["comp/discovery/#"]) mqtt_client_mock.unsubscribe.reset_mock() async_fire_mqtt_message(hass, "comp/discovery/bla/config", "") - await asyncio.sleep(0.1) + await asyncio.sleep(0) + await hass.async_block_till_done() await hass.async_block_till_done() assert not mqtt_client_mock.unsubscribe.called