refactored 3
This commit is contained in:
@@ -296,7 +296,7 @@ async def mqtt_worker(config: dict[str, Any], redis_client: aioredis.Redis) -> N
|
|||||||
) as client:
|
) as client:
|
||||||
logger.info(f"Connected to MQTT broker as {unique_client_id}")
|
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
|
# Subscribe to topics for all devices
|
||||||
for device in devices.values():
|
for device in devices.values():
|
||||||
device_id = device['device_id']
|
device_id = device['device_id']
|
||||||
|
|||||||
Reference in New Issue
Block a user