Index: tests/dg_valves_test.py
===================================================================
diff -u -re97c499a943e83a39b0c1b41a7d41b706001253d -r49f99c3f4a045652f1a32ad24a47fc1710ebc352
--- tests/dg_valves_test.py	(.../dg_valves_test.py)	(revision e97c499a943e83a39b0c1b41a7d41b706001253d)
+++ tests/dg_valves_test.py	(.../dg_valves_test.py)	(revision 49f99c3f4a045652f1a32ad24a47fc1710ebc352)
@@ -1 +1,58 @@
+###########################################################################
+#
+#  Copyright (c) 2019-2020 Diality Inc. - All Rights Reserved.
+#
+#  THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
+#  WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
+#
+#  @file dg_valves_test.py
+#
+#  @date 20-May-2020
+#  @author P. Montazemi
+#
+#  @brief This development test script exercises the DG valves states in \n
+#  single and batch modes
+#
+############################################################################
+
+import sys
+sys.path.append("..")
+from dialin.dg.dialysate_generator import DG
+from time import sleep
+
+if __name__ == "__main__":
+    # Create an instance of the DG Class called dg
+    dg = DG()
+    sleep(2)
+
+    # Log in to DG as tester
+    if dg.cmd_log_in_to_dg() == 0:
+        print("DG login failed.")
+        exit(1)
+    sleep(1)
+
+    # Create log file
+    with open("DG_valves_test.log", "w") as f:
+        # Collect DG valves states
+        while True:
+            sleep(1)
+            valvesStates = "DGValves.VBF," + str(dg.valves.valve_state_VRF) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VRI) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VRD) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VRO) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VPO) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VBF) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VRC) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VDR) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VPI) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VSP) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VR1) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VR2) + \
+                           ",DGValves.VDR," + str(dg.valves.valve_state_VPD)
+
+            # Log data
+            f.write(valvesStates)
+            f.write("\n")
+
+            # Print to console
+            print("DG Valves States: "+valvesStates)