Index: dialin/dg/dialysate_generator.py
===================================================================
diff -u -r3765a2a0a45ddf65c99604f12ac635884ff8dc09 -r4c6c02d823b8aa40f92586704ad307730073ddc3
--- dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 3765a2a0a45ddf65c99604f12ac635884ff8dc09)
+++ dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 4c6c02d823b8aa40f92586704ad307730073ddc3)
@@ -55,6 +55,7 @@
 from .dg_test_configs import DGTestConfig
 from .ro_permeate_sample import ROPermeateSample
 from .drain import DGDrain
+from .watchdog import DGWatchdog
 from ..common.msg_defs import MsgIds, MsgFieldPositions
 from enum import unique
 from .constants import NO_RESET
@@ -214,6 +215,7 @@
         self.test_configs = DGTestConfig(self.can_interface, self.logger)
         self.ro_permeate_sample = ROPermeateSample(self.can_interface, self.logger)
         self.drain = DGDrain(self.can_interface, self.logger)
+        self.watchdog = DGWatchdog(self.can_interface, self.logger)
 
     def __del__(self):
         self.can_interface.transmit_interval_dictionary[self.callback_id].stop()