From 29e2fd441bc7489c5b7acaa9fb2ae038b6df2796 Mon Sep 17 00:00:00 2001 From: Wolfgang Hottgenroth Date: Tue, 18 Nov 2025 14:25:09 +0100 Subject: [PATCH] refactored 4 --- apps/abstraction/main.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/apps/abstraction/main.py b/apps/abstraction/main.py index 40cf28b..48e69c2 100644 --- a/apps/abstraction/main.py +++ b/apps/abstraction/main.py @@ -328,7 +328,8 @@ async def mqtt_worker(config: dict[str, Any], redis_client: aioredis.Redis) -> N last_activity = asyncio.get_event_loop().time() topic = str(message.topic) payload_str = message.payload.decode() - logger.debug(f"MQTT message received on {topic}: {payload_str}") + retain = getattr(message, 'retain', None) + logger.debug(f"MQTT message received on ({retain=}) {topic}: {payload_str}") # Check if this is an abstract SET message if topic.startswith("home/") and topic.endswith("/set"):