Bump version to 0.9.12.4; add topic to MQTTManager inputs for enhanced message handling

Author: legout

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.12.3"
+version = "0.9.12.4"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   'aiobotocore<2.18.0',

src/flowerpower/mqtt.py

@@ -336,6 +336,7 @@ def on_message(client, userdata, msg):
             logger.info(f"Received message on topic {topic}")
 
             inputs["payload"] = msg.payload
+            inputs["topic"] = msg.topic
 
             with Pipeline(
                 name=name, storage_options=storage_options, fs=fs, base_dir=base_dir