Index: leahi_dialin/td/modules/air_pump.py
===================================================================
diff -u -r2d1aa1133cbaac4adbf4b6f7b2512f6b9255063f -r3c2bc6419b5796c03a7e4943938055c4ac36c24b
--- leahi_dialin/td/modules/air_pump.py	(.../air_pump.py)	(revision 2d1aa1133cbaac4adbf4b6f7b2512f6b9255063f)
+++ leahi_dialin/td/modules/air_pump.py	(.../air_pump.py)	(revision 3c2bc6419b5796c03a7e4943938055c4ac36c24b)
@@ -16,11 +16,11 @@
 
 # Module imports
 from logging import Logger
-
+import time
 # Project imports
 from leahi_dialin.common.constants import NO_RESET
 from leahi_dialin.common.generic_defs import DataTypes
-from leahi_dialin.common.msg_defs import MsgIds
+from leahi_dialin.common.msg_ids import MsgIds
 from leahi_dialin.common.override_templates import cmd_generic_broadcast_interval_override, cmd_generic_override
 from leahi_dialin.common import td_enum_repository
 from leahi_dialin.protocols.CAN import CanMessenger, CanChannels
@@ -32,8 +32,6 @@
 
 class TDAirPump(AbstractSubSystem):
     """
-    TDAirPump
-
     Treatment Delivery (TD) Dialin API sub-class for air pump related commands.
     """
 
@@ -64,6 +62,7 @@
                 td_enum_repository.TDAirPumpAttributes.SCALAR_POWER.name: 0
             }
         }
+        self.handler_execution_times = []
 
 
     @publish(["msg_id_td_air_pump_data", "td_air_pump", "td_air_pump_timestamp"])
@@ -74,6 +73,7 @@
         @param message:  published air pump data message as: air pump state
         @return: None
         """
+        start = time.perf_counter()
         sensor_list =[]
         sensor_list.append((td_enum_repository.TDAirPumpNames.H12_AIR_PUMP.name, td_enum_repository.TDAirPumpAttributes.STATE.name,         DataTypes.U32))
         sensor_list.append((td_enum_repository.TDAirPumpNames.H12_AIR_PUMP.name, td_enum_repository.TDAirPumpAttributes.DUTY_CYCLE.name,    DataTypes.F32))
@@ -87,6 +87,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.td_air_pump_timestamp = timestamp
+        self.handler_execution_times.append((timestamp, message, time.perf_counter() - start))
 
 
     def cmd_air_pump_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: