diff --git a/apps/pulsegen/main.py b/apps/pulsegen/main.py index 99a5406..55487a5 100644 --- a/apps/pulsegen/main.py +++ b/apps/pulsegen/main.py @@ -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")