Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
d3c1ec404a
|
@@ -5,6 +5,7 @@ import json
|
||||
import logging
|
||||
import os
|
||||
import signal
|
||||
import uuid
|
||||
from typing import Any
|
||||
|
||||
from aiomqtt import Client, Message
|
||||
@@ -163,7 +164,7 @@ async def mqtt_worker(shutdown_event: asyncio.Event) -> None:
|
||||
async with Client(
|
||||
hostname=broker,
|
||||
port=port,
|
||||
identifier="pulsegen"
|
||||
identifier=f"pulsegen-{uuid.uuid4()}",
|
||||
) as client:
|
||||
logger.info("Connected to MQTT broker")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user