Index: leahi_dialin/dd/proxies/td_proxy.py
===================================================================
diff -u -r18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df -r38e8dd31728056dbb7f9304c98ab16d7147b75a2
--- leahi_dialin/dd/proxies/td_proxy.py	(.../td_proxy.py)	(revision 18c90a1b2b6c7339bdd192a2d2fac32f2b8a35df)
+++ leahi_dialin/dd/proxies/td_proxy.py	(.../td_proxy.py)	(revision 38e8dd31728056dbb7f9304c98ab16d7147b75a2)
@@ -132,3 +132,33 @@
 
         self.logger.debug("Sending TD start pre gen request to DD.")
         self.can_interface.send(message, 0)
+
+    def cmd_td_override_treatment_parameter(self, paramID: int, value, reset: int = 0):
+        """
+        Constructs and sends a treatment parameter override request.
+        @param paramID : integer - Treatment parameter ID
+        @param value   : float or integer - Override value
+        @param reset   : integer 1 to reset override, 0 to apply override
+        @returns None
+        """
+
+        rst = integer_to_bytearray(reset)
+        pid = integer_to_bytearray(paramID)
+        # Dialysate rate, UF rate and dialysate temperature are f32
+        float_params = [ 0, 1, 2 ]
+        # Acid type and bicarbonate type are u32
+        uint_params = [ 3, 4 ]
+        if paramID in float_params:
+            val = float_to_bytearray(float(value))
+        elif paramID in uint_params:
+            val = integer_to_bytearray(int(value))
+        else:
+            val = integer_to_bytearray(int(value))
+        payload = rst + val + pid
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dd_ch_id,
+                                              message_id=MsgIds.MSG_ID_DD_TREATMENT_PARAMS_OVERRIDE_REQUEST.value,
+                                              payload=payload)
+
+        self.logger.debug("Sending DD treatment parameter override: id={}, value={}, reset={}".format( paramID, value, reset))
+        self.can_interface.send(message, 0)