From f902f4038652c0412e0b377f5bf7474264b3254e Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Tue, 18 Nov 2025 14:12:08 +0100 Subject: [PATCH] refactored 3 --- apps/abstraction/main.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/abstraction/main.py b/apps/abstraction/main.py index ff142cd..40cf28b 100644 --- a/apps/abstraction/main.py +++ b/apps/abstraction/main.py @@ -296,7 +296,7 @@ async def mqtt_worker(config: dict[str, Any], redis_client: aioredis.Redis) -> N ) as client: logger.info(f"Connected to MQTT broker as {unique_client_id}") - async with client.messages() as messages: + async with client.messages as messages: # Subscribe to topics for all devices for device in devices.values(): device_id = device['device_id']