Index: leahi_dialin/fp/modules/flow_sensors.py
===================================================================
diff -u -r0f08c28544b557b2bbd8c04b10cff284f41e4fb9 -rd28c8c54ba1f74adf348d1db6f5bfe034628c812
--- leahi_dialin/fp/modules/flow_sensors.py	(.../flow_sensors.py)	(revision 0f08c28544b557b2bbd8c04b10cff284f41e4fb9)
+++ leahi_dialin/fp/modules/flow_sensors.py	(.../flow_sensors.py)	(revision d28c8c54ba1f74adf348d1db6f5bfe034628c812)
@@ -34,7 +34,7 @@
 class FPFlowSensors(AbstractSubSystem):
     """
 
-        Dialin API sub-class for flow sensor related commands.
+         API sub-class for FP flow sensor related commands.
     """
 
     def __init__(self, can_interface, logger: Logger):
@@ -61,7 +61,7 @@
 
         self.fp_flow_timestamp = 0
 
-    @publish(["fp_levels_timestamp",
+    @publish(["fp_flows_timestamp",
                 "p7_flowFMS", "p16_flowFMP",
                 "p7_tempFMS", "p16_tempFMP"])
     def _handler_flow_sensor_sync(self, message, timestamp=0.0):
@@ -80,7 +80,7 @@
         self.p16_tempFMP = struct.unpack('f', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4]))[0]
 
-        self.fp_flow_timestamp = timestamp
+        self.fp_flows_timestamp = timestamp
 
     def cmd_flow_sensor_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int:
         """