Index: dialin/dg/dialysate_generator.py
===================================================================
diff -u -r5d58d1eeb80237a7cafbb31bc800cb29e19615e0 -r6187d1a877c75a0601e2ffda1ab1972622d1b66e
--- dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 5d58d1eeb80237a7cafbb31bc800cb29e19615e0)
+++ dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 6187d1a877c75a0601e2ffda1ab1972622d1b66e)
@@ -107,7 +107,7 @@
             msg_id = self.MSG_ID_DG_OPERATION_MODE_BROADCAST
             self.can_interface.register_receiving_publication_function(channel_id, msg_id,
                                                                        self.handler_dg_op_mode_sync)
-                                                                       #self._handler_dg_op_mode_sync) This was in staging branch commented out
+                                                                       self._handler_dg_op_mode_sync)
             self.can_interface.register_receiving_publication_function(DenaliChannels.dg_sync_broadcast_ch_id,
                                                                        self.MSG_ID_DG_DG_VERSION_RESPONSE,
                                                                        self._handler_dg_version)
Index: tests/dg_heatdisinfect.py
===================================================================
diff -u
--- tests/dg_heatdisinfect.py	(revision 0)
+++ tests/dg_heatdisinfect.py	(revision 6187d1a877c75a0601e2ffda1ab1972622d1b66e)
@@ -0,0 +1,14 @@
+
+
+import sys
+sys.path.append("..")
+from dialin.dg.dialysate_generator import DG
+from time import sleep
+
+if __name__ == "__main__":
+
+    dg = DG()
+    dg.cmd_log_in_to_dg()
+    dg.ro_pump.cmd_ro_flow_rate_override(0.6)
+
+    print(dg.ro_pump.measured_flow_rate_lpm)