Index: dialin/dg/flush.py
===================================================================
diff -u -r7ea4b936cef531b2cde9053ae58b7119a3bf0e6c -r7316136f3e2aa7c299f6a3a4a48dab8cbaf0e555
--- dialin/dg/flush.py	(.../flush.py)	(revision 7ea4b936cef531b2cde9053ae58b7119a3bf0e6c)
+++ dialin/dg/flush.py	(.../flush.py)	(revision 7316136f3e2aa7c299f6a3a4a48dab8cbaf0e555)
@@ -34,7 +34,7 @@
         self.can_interface = can_interface
         self.logger = logger
 
-        self.flush_state = 0
+        self.flush_state = DGFlushStates.DG_FLUSH_STATE_START.value
         self.overall_elapsed_time = 0
         self.state_elapsed_time = 0
         self.flush_drain_line_volume_l = 0.0
@@ -44,6 +44,15 @@
             msg_id = MsgIds.MSG_ID_DG_FLUSH_DATA.value
             self.can_interface.register_receiving_publication_function(channel_id, msg_id, self._handler_flush_sync)
 
+    def clear_flush_state(self) -> None:
+        """
+        Clears the flush state locally.
+
+        @param none
+        @returns none
+        """
+        self.flush_state = DGFlushStates.DG_FLUSH_STATE_START.value
+
     @publish(["flush_state", "overall_elapsed_time", "state_elapsed_time", "flush_drain_line_volume"])
     def _handler_flush_sync(self, message: dict) -> None:
         """