Bump version to 0.9.9.5; improve logging messages in MQTTManager for …

…clarity
legout · Feb 17, 2025 · 0bf4c3f · 0bf4c3f
1 parent e9bf514
commit 0bf4c3f
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -4,7 +4,7 @@ description = "A simple workflow framework. Hamilton + APScheduler = FlowerPower
 authors = [{ name = "Volker L.", email = "[email protected]" }]
 readme = "README.md"
 requires-python = ">= 3.11"
-version = "0.9.9.4"
+version = "0.9.9.5"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   'aiobotocore<2.18.0',

diff --git a/src/flowerpower/mqtt.py b/src/flowerpower/mqtt.py
@@ -323,7 +323,7 @@ def start_pipeline_listener(
             inputs = {}
 
         def on_message(client, userdata, msg):
-            logger.info("Message arrived")
+            logger.info(f"Received message on topic {topic}")
 
             inputs["payload"] = msg.payload
 
@@ -363,7 +363,7 @@ def on_message(client, userdata, msg):
                     _ = e
                     logger.exception(e)
 
-                logger.warning("processing failed")
+                logger.warning("Message processing failed")
 
         self.start_listener(on_message=on_message, topic=topic, background=background)
 

diff --git a/uv.lock b/uv.lock