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"):