From ecad0ce15bc5cd34248be75e7bd37d0aae8836fc Mon Sep 17 00:00:00 2001 From: Andrew Mirsky Date: Thu, 26 Jun 2025 13:33:13 -0400 Subject: [PATCH] updating sample to demonstrate failure --- samples/client_publish.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/samples/client_publish.py b/samples/client_publish.py index cd10ed1..135fb57 100644 --- a/samples/client_publish.py +++ b/samples/client_publish.py @@ -35,7 +35,7 @@ async def test_coro1() -> None: async def test_coro2() -> None: try: - client = MQTTClient(config={'auto_connect': False}) + client = MQTTClient(config={'auto_reconnect': False, 'connection_timeout': 1}) await client.connect("mqtt://localhost:1884/") await client.publish("a/b", b"TEST MESSAGE WITH QOS_0", qos=0x00) await client.publish("a/b", b"TEST MESSAGE WITH QOS_1", qos=0x01) @@ -43,7 +43,7 @@ async def test_coro2() -> None: logger.info("test_coro2 messages published") await client.disconnect() except ConnectError: - logger.exception(f"Connection failed", exc_info=True) + logger.info(f"Connection failed", exc_info=True) def __main__():