From 51d8c838f7f21dba8792ee3fb9dd77ff05228bac Mon Sep 17 00:00:00 2001 From: Andrew Mirsky Date: Wed, 2 Jul 2025 14:01:53 -0400 Subject: [PATCH] client reconnecting too quickly causing connection failure --- tests/test_broker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/test_broker.py b/tests/test_broker.py index 0a05994..49bdccd 100644 --- a/tests/test_broker.py +++ b/tests/test_broker.py @@ -691,12 +691,12 @@ async def test_client_publish_clean_session_subscribe(broker): await _client_publish("/qos0", b"data0", QOS_0) # should not be retained await _client_publish("/qos1", b"data1", QOS_1) await _client_publish("/qos2", b"data2", QOS_2) - await asyncio.sleep(0.5) + await asyncio.sleep(2) await sub_client.reconnect(cleansession=False) for qos in [QOS_1, QOS_2]: log.debug(f"TEST QOS: {qos}") - message = await sub_client.deliver_message() + message = await sub_client.deliver_message(timeout_duration=2) log.debug(f"Message: {message.publish_packet if message else None!r}") assert message is not None assert message.topic == f"/qos{qos}"