Index: dialin/dg/dialysate_generator.py
===================================================================
diff -u -r45f70ed84010200e8582a25ccd8792100f4f4fc4 -rc2339249c8fc4a2034e0f66bc024ea36dbf7c2a4
--- dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision 45f70ed84010200e8582a25ccd8792100f4f4fc4)
+++ dialin/dg/dialysate_generator.py	(.../dialysate_generator.py)	(revision c2339249c8fc4a2034e0f66bc024ea36dbf7c2a4)
@@ -344,6 +344,51 @@
 
         self.can_interface.send(message, 0)
 
+    def cmd_dg_set_operation_mode(self, new_mode: int = 0) -> int:
+        """
+        Constructs and sends a set operation mode request command via CAN bus.
+        Constraints:
+            Must be logged into DG.
+            Transition from current to requested op mode must be legal.
+
+        @param new_mode:  ID of operation mode to transition to
+            DG_MODE_FAUL = 0
+            DG_MODE_SERV = 1
+            DG_MODE_INIT = 2
+            DG_MODE_STAN = 3
+            DG_MODE_SOLO = 4
+            DG_MODE_GENE = 5
+            DG_MODE_FILL = 6
+            DG_MODE_DRAI = 7
+            DG_MODE_FLUS = 8
+            DG_MODE_HEAT = 9
+            DG_MODE_CHEM = 10
+
+        @return: 1 if successful, zero otherwise
+
+        """
+
+        payload = integer_to_bytearray(new_mode)
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dg_ch_id,
+                                              message_id=MsgIds.MSG_ID_DG_SET_OP_MODE_REQUEST.value,
+                                              payload=payload)
+
+        self.logger.debug("Requesting DG mode change to " + str(new_mode))
+
+        # Send message
+        received_message = self.can_interface.send(message)
+
+        if received_message is not None:
+            if received_message['message'][DenaliMessage.PAYLOAD_START_INDEX] == 1:
+                self.logger.debug("Success: Mode change accepted")
+            else:
+                self.logger.debug("Failure: Mode change rejected.")
+            return received_message['message'][DenaliMessage.PAYLOAD_START_INDEX]
+        else:
+            self.logger.debug("DG mode change request Timeout!!!!")
+            return False
+
     def cmd_dg_safety_shutdown_override(self) -> int:
         """
         Constructs and sends an DG safety shutdown override command via CAN bus.