Skip to content
Snippets Groups Projects
Commit 7209bb95 authored by Hannes Feldt's avatar Hannes Feldt
Browse files

Merge branch 'fix-tcp-replicator' into 'master'

Fix tcp replicator

See merge request !784
parents 5c14a4e9 8911b798
No related branches found
No related tags found
1 merge request!784Fix tcp replicator
0.24.6
0.24.7
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment