From 8911b798f8abc3916a6739f15a2b9536ac6a78f5 Mon Sep 17 00:00:00 2001
From: Hannes Feldt <feldt@astron.nl>
Date: Fri, 24 Nov 2023 16:22:45 +0100
Subject: [PATCH] Fix tcp replicator
---
tangostationcontrol/VERSION | 2 +-
.../tangostationcontrol/clients/statistics/consumer.py | 5 ++++-
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/tangostationcontrol/VERSION b/tangostationcontrol/VERSION
index b9c51a1a9..c9731ff41 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 dea33f22a..5372ea1ba 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
--
GitLab