update version

This commit is contained in:
Pablo Revilla
2025-06-24 12:31:22 -07:00
parent b1106d8558
commit 33a0992c97
+1
View File
@@ -33,6 +33,7 @@ async def get_topic_envelopes(mqtt_server, mqtt_port, topics, mqtt_user, mqtt_pa
mqtt_server, port=mqtt_port , username=mqtt_user, password=mqtt_passwd , identifier=identifier,
) as client:
for topic in topics:
print(topic)
await client.subscribe(topic)
async for msg in client.messages:
try: