Index: dialin/dg/dialysate_generator.py
===================================================================
diff -u -r91f03e107b6892081a3b96525d8a83fb7304f813 -r03b059d55d9d3797ff25575688a6a597f2c06b7b
--- dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 91f03e107b6892081a3b96525d8a83fb7304f813)
+++ dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 03b059d55d9d3797ff25575688a6a597f2c06b7b)
@@ -414,15 +414,26 @@
             self.logger.debug("DG mode change request Timeout!!!!")
             return False
 
-    def cmd_dg_safety_shutdown_override(self) -> int:
+    def cmd_dg_safety_shutdown_override(self, active: bool = True, reset: int = NO_RESET) -> int:
         """
         Constructs and sends an DG safety shutdown override command via CAN bus.
 
+        @param active:  boolean - True to activate safety shutdown, False to deactivate
+        @param reset:  integer - 1 to reset a previous override, 0 to override
         @return: 1 if successful, zero otherwise
         """
 
+        if active:
+            sft = 1
+        else:
+            sft = 0
+        rst = integer_to_bytearray(reset)
+        saf = integer_to_bytearray(sft)
+        payload = rst + saf
+
         message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id,
-                                              message_id=MsgIds.MSG_ID_DG_SAFETY_SHUTDOWN_OVERRIDE.value)
+                                              message_id=MsgIds.MSG_ID_DG_SAFETY_SHUTDOWN_OVERRIDE.value,
+                                              payload=payload)
 
         self.logger.debug("overriding DG safety shutdown")