Index: leahi_dialin/dd/modules/conductivity_sensors.py
===================================================================
diff -u -r6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499 -rc4b92f4de01ac39942ccdc1a18d9dd85be31a2c0
--- leahi_dialin/dd/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision 6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499)
+++ leahi_dialin/dd/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision c4b92f4de01ac39942ccdc1a18d9dd85be31a2c0)
@@ -16,6 +16,7 @@
 
 # Module imports
 from logging import Logger
+import time
 
 # Project imports
 from leahi_dialin.common.constants import NO_RESET
@@ -97,6 +98,9 @@
             },
         }
 
+        self.handler_cond_execution_times = []
+        self.handler_resist_execution_times = []
+
     @publish(["msg_id_dd_conductivity_data", "dd_conductivity", "dd_conductivity_timestamp"])
     def _handler_conductivity_sensors_sync(self, message, timestamp=0.0):
         """
@@ -106,6 +110,7 @@
         @param message:  published DD conductivity sensor data message
         @return: None
         """
+        start = time.perf_counter()
         sensor_list =[]
         sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D17_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32))
         sensor_list.append((dd_enum_repository.DDConductivitySensorNames.D27_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32))
@@ -131,7 +136,8 @@
         self.process_into_dict(dict_to_update = self.dd_conductivity,
                                decoder_list = sensor_list,
                                message = message)
-        self.dd_conductivity_timestamp = timestamp
+        self.dd_conductivity_resistance_timestamp = timestamp
+        self.handler_resist_execution_times.append(time.perf_counter() - start)
 
     @publish(["msg_id_dd_conductivity_version_data", "dd_conductivity_resistance", "dd_conductivity_version_timestamp"])
     def _handler_conductivity_version_sync(self, message, timestamp=0.0):
Index: leahi_dialin/fp/modules/conductivity_sensors.py
===================================================================
diff -u -r6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499 -rc4b92f4de01ac39942ccdc1a18d9dd85be31a2c0
--- leahi_dialin/fp/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision 6ce1aaaa1c5ce4ef44d51d7c805c81e34cdb2499)
+++ leahi_dialin/fp/modules/conductivity_sensors.py	(.../conductivity_sensors.py)	(revision c4b92f4de01ac39942ccdc1a18d9dd85be31a2c0)
@@ -16,6 +16,7 @@
 
 # Module imports
 from logging import Logger
+import time
 
 # Project imports
 from leahi_dialin.common.constants import NO_RESET
@@ -82,6 +83,8 @@
             fp_enum_repository.FPRORejectionRatioNames.GEN_PERMEATE_STATE.name: 0
         }
 
+        self.handler_execution_times = []
+        self.handler_ro_execution_times = []
 
     @publish(["msg_id_fp_conductivity_data", "fp_conductivity", "fp_conductivity_timestamp"])
     def _handler_conductivity_sensors_sync(self, message, timestamp=0.0):
@@ -92,6 +95,7 @@
         @param message:  published conductivity sensor data message
         @return: None
         """
+        start = time.perf_counter()
         sensor_list =[]
         sensor_list.append((fp_enum_repository.FPConductivitySensorNames.P9_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32))
         sensor_list.append((fp_enum_repository.FPConductivitySensorNames.P18_COND.name, dd_enum_repository.DDConductivityResistanceAttributes.CONDUCTIVITY.name, DataTypes.F32))
@@ -106,6 +110,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.fp_conductivity_timestamp = timestamp
+        self.handler_execution_times.append(time.perf_counter() - start)
 
 
     @publish(["msg_id_ro_rejection_ratio_data", "ro_rejection_ratio", "ro_rejection_ratio_timestamp"])
@@ -117,6 +122,7 @@
         @param message: Published RO Rejection Ratio data message
         @return: None
         """
+        start = time.perf_counter()
         sensor_list =[]
         sensor_list.append((fp_enum_repository.FPRORejectionRatioNames.RAW_RO_REJECTION_RATIO.name,             DataTypes.F32))
         sensor_list.append((fp_enum_repository.FPRORejectionRatioNames.RAW_RO_REJECTION_RATIO_TANK_FILL.name,   DataTypes.F32))
@@ -128,6 +134,7 @@
                                decoder_list = sensor_list,
                                message = message)
         self.ro_rejection_ratio_timestamp = timestamp
+        self.handler_ro_execution_times.append(time.perf_counter() - start)
 
 
     def cmd_conductivity_sensor_data_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: