Index: leahi_dialin/fp/modules/permeate_tank.py =================================================================== diff -u -r5c1132f5aadff6082afa56588ad1f4a64f828cd9 -r6caa49d072aceb2655d605de5d2eea52ab1a8911 --- leahi_dialin/fp/modules/permeate_tank.py (.../permeate_tank.py) (revision 5c1132f5aadff6082afa56588ad1f4a64f828cd9) +++ leahi_dialin/fp/modules/permeate_tank.py (.../permeate_tank.py) (revision 6caa49d072aceb2655d605de5d2eea52ab1a8911) @@ -50,9 +50,26 @@ function = self._handler_permeate_tank_sync) self.permeate_tank_timestamp = 0.0 #: The timestamp of the last message - self.permeate_tank_state = 0 #: The Permeate Tank's State value + self.permeate_tank_state = 0 self.handler_execution_times = [] + + +# ============================================================ Properties ============================================================ + @property + def permeate_tank_state(self) -> int: + """ + The Permeate Tank state + """ + return self._permeate_tank_state + + @permeate_tank_state.setter + def permeate_tank_state(self, value): + self._permeate_tank_state = value + + + +# ============================================================ Handlers ============================================================ @publish(["msg_id_fp_permeate_tank_data", "permeate_tank_state", "permeate_tank_timestamp"]) def _handler_permeate_tank_sync(self, message, timestamp=0.0): """ @@ -63,14 +80,15 @@ """ start = time.perf_counter() msg_list =[] - msg_list.append(('self.permeate_tank_state', DataTypes.U32)) + msg_list.append((type(self).permeate_tank_state, DataTypes.U32)) - self.process_into_vars(decoder_list = msg_list, - message = message) + self.process_into_vars(decoder_list = msg_list, message = message) self.permeate_tank_timestamp = timestamp self.handler_execution_times.append((timestamp, message, time.perf_counter() - start)) + +# ============================================================ Overrides and Requests ============================================================ def cmd_permeate_tank_broadcast_interval_override(self, ms: int, reset: int = NO_RESET) -> int: """ Constructs and sends the broadcast time interval override for permeate tank data.