Index: dialin/dg/flush.py
===================================================================
diff -u -r71a18fc40dc40519d50aa7888405dbcd4c4cad25 -r321f2cec2f2bcade5d2ae0b07a8cae9239c0e231
--- dialin/dg/flush.py	(.../flush.py)	(revision 71a18fc40dc40519d50aa7888405dbcd4c4cad25)
+++ dialin/dg/flush.py	(.../flush.py)	(revision 321f2cec2f2bcade5d2ae0b07a8cae9239c0e231)
@@ -57,7 +57,7 @@
         self.overall_elapsed_time = 0
         self.state_elapsed_time = 0
 
-    @publish(["flush_state", "overall_elapsed_time", "state_elapsed_time", "flush_drain_line_volume",
+    @publish(["flush_state", "overall_elapsed_time", "state_elapsed_time", "flush_drain_line_volume_l",
               "flush_UI_state"])
     def _handler_flush_sync(self, message: dict) -> None:
         """
@@ -66,15 +66,15 @@
         @param message:  published flush data message
         @returns none
         """
-        state = struct.unpack('<i', bytearray(
+        state = struct.unpack('<I', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_1:MsgFieldPositions.END_POS_FIELD_1]))[0]
-        elapsed_time = struct.unpack('<i', bytearray(
+        elapsed_time = struct.unpack('<I', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_2:MsgFieldPositions.END_POS_FIELD_2]))[0]
-        state_elapsed_time = struct.unpack('<i', bytearray(
+        state_elapsed_time = struct.unpack('<I', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_3:MsgFieldPositions.END_POS_FIELD_3]))[0]
         drain_line_volume = struct.unpack('<f', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4]))[0]
-        flush_ui_state = struct.unpack('<f', bytearray(
+        flush_ui_state = struct.unpack('<I', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_5:MsgFieldPositions.END_POS_FIELD_5]))[0]
 
         self.flush_state = state