diff --git a/tangostationcontrol/VERSION b/tangostationcontrol/VERSION index b9c51a1a9cfe8b920a2630b8dc6b311f02fc6a50..c9731ff41861f2d4122dc88c8c7a2df7132a9e06 100644 --- a/tangostationcontrol/VERSION +++ b/tangostationcontrol/VERSION @@ -1 +1 @@ -0.24.6 +0.24.7 diff --git a/tangostationcontrol/tangostationcontrol/clients/statistics/consumer.py b/tangostationcontrol/tangostationcontrol/clients/statistics/consumer.py index dea33f22a21077a68572fc1abf8d611b47c6e62e..5372ea1ba6d51324fe4385ac6a9c213aa69f6e35 100644 --- a/tangostationcontrol/tangostationcontrol/clients/statistics/consumer.py +++ b/tangostationcontrol/tangostationcontrol/clients/statistics/consumer.py @@ -7,6 +7,7 @@ from queue import Queue from threading import Thread from lofar_station_client.statistics.collector import StatisticsCollector +from lofar_station_client.statistics.packets import StatisticsPacket from tangostationcontrol.clients.statistics.client_thread import StatisticsClientThread logger = logging.getLogger() @@ -70,7 +71,9 @@ class StatisticsConsumer(Thread, StatisticsClientThread): break try: - self.collector.process_packet(self.last_packet) + self.collector.process_packet( + StatisticsPacket.parse_packet(self.last_packet) + ) except ValueError as e: self._exception_logging(e) # continue processing