Index: leahi_dialin/dd/modules/concentrate_pump.py =================================================================== diff -u -rc5bfcf84ed942ca5841bf9de155aa0f495b4d28d -r20c821bd230fc7689a0275a2918981669ff5cc19 --- leahi_dialin/dd/modules/concentrate_pump.py (.../concentrate_pump.py) (revision c5bfcf84ed942ca5841bf9de155aa0f495b4d28d) +++ leahi_dialin/dd/modules/concentrate_pump.py (.../concentrate_pump.py) (revision 20c821bd230fc7689a0275a2918981669ff5cc19) @@ -18,7 +18,7 @@ from logging import Logger from leahi_dialin.common.constants import NO_RESET -from leahi_dialin.common.dd_defs import dd_enum_repository +from leahi_dialin.common import dd_enum_repository from leahi_dialin.common.msg_defs import MsgIds, MsgFieldPositions from leahi_dialin.common.override_templates import cmd_generic_broadcast_interval_override, cmd_generic_override from leahi_dialin.protocols.CAN import DenaliChannels @@ -46,6 +46,9 @@ self.can_interface.register_receiving_publication_function(channel_id, self.msg_id_dd_conc_pump_data, self._handler_concentrate_pumps_sync) + self.dd_concentrate_pump_timestamp = 0.0 #: The timestamp of the last message + + #: The Concentrate Pumps data in dictionary format self.dd_concentrate_pumps = { dd_enum_repository.DDConcentratePumpNames.D10_CP2_BICARB.name: { dd_enum_repository.DDConcentratePumpAttributes.CURRENT_STATE.name: 0, @@ -82,9 +85,7 @@ } } - self.dd_concentrate_pump_timestamp = 0.0 - @publish(["msg_id_dd_conc_pump_data", "dd_concentrate_pumps", "dd_concentrate_pump_timestamp"]) def _handler_concentrate_pumps_sync(self, message, timestamp=0.0): """