diff --git a/cbpi/__init__.py b/cbpi/__init__.py
index 231f90e..5285c9f 100644
--- a/cbpi/__init__.py
+++ b/cbpi/__init__.py
@@ -1,3 +1,3 @@
-__version__ = "4.3.2.a9"
+__version__ = "4.3.2.a10"
 __codename__ = "Winter Storm"
 
diff --git a/cbpi/controller/fermentation_controller.py b/cbpi/controller/fermentation_controller.py
index 4b6a1f3..512a528 100644
--- a/cbpi/controller/fermentation_controller.py
+++ b/cbpi/controller/fermentation_controller.py
@@ -545,12 +545,19 @@ class FermentationController:
 
             # send mqtt update for active femrentersteps
             for fermenter in fermentersteps:
+                active = False
                 for step in fermenter['steps']:
                     if step['status'] == 'A':
+                        active=True
+                        active_step=step
 #                        self.cbpi.push_update("cbpi/{}/{}/{}".format(key,fermenter['id'],step['id']), step)
-                        self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), step)
                     #else:
-                    #    self.cbpi.push_update("cbpi/{}/{}/{}".format(key,fermenter['id'],step['id']), "")
+                    #    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), "")
+                if active:
+                    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), active_step)
+                else:
+                    self.cbpi.push_update("cbpi/{}/{}".format(key,fermenter['id']), "")
+
                         
         
     async def call_action(self, id, action, parameter) -> None: