Index: tests/fp_dianogistic_logger.py =================================================================== diff -u -r9ccbc0c7610d431e94566f93014f3a9663c4488c -red7b0b3a37ce5a6b7a8c81c5d7d37785949abdf5 --- tests/fp_dianogistic_logger.py (.../fp_dianogistic_logger.py) (revision 9ccbc0c7610d431e94566f93014f3a9663c4488c) +++ tests/fp_dianogistic_logger.py (.../fp_dianogistic_logger.py) (revision ed7b0b3a37ce5a6b7a8c81c5d7d37785949abdf5) @@ -22,6 +22,7 @@ fp_level_recorder, fp_flow_recorder, fp_conductivity_recorder, fp_valve_recorder, fp_ro_pump_recorder, fp_boost_pump_recorder, \ fp_op_mode_recorder, fp_combine_logs, fp_log_setup from leahi_dialin.fp.filtration_purification import FP +from leahi_dialin.dd.dialysate_delivery import DD RECORDING_INTERVAL = 0.25 RECORDING_INTERVAL_IN_MS = int(RECORDING_INTERVAL * 1000) @@ -53,6 +54,7 @@ try: # create a FP object called fp fp = FP(log_level="DEBUG") + dd = DD() # log in to fp as a tester if fp.cmd_log_in_to_fp() == 0: @@ -71,7 +73,7 @@ level_log_writer_thread = threading.Thread(target=fp_level_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) flows_log_writer_thread = threading.Thread(target=fp_flow_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) conductivity_log_writer_thread = threading.Thread(target=fp_conductivity_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) - valve_log_writer_thread = threading.Thread(target=fp_valve_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) + valve_log_writer_thread = threading.Thread(target=fp_valve_recorder, args=(fp, dd, RECORDING_INTERVAL), daemon=True) ro_log_writer_thread = threading.Thread(target=fp_ro_pump_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) boost_log_writer_thread = threading.Thread(target=fp_boost_pump_recorder, args=(fp, RECORDING_INTERVAL), daemon=True) opmode_log_writer_thread = threading.Thread(target=fp_op_mode_recorder, args=(fp, RECORDING_INTERVAL), daemon=True)