Skip to content
Snippets Groups Projects
Commit 79dcec4e authored by Corné Lukken's avatar Corné Lukken
Browse files

L2SS-868: Correct imports for migration to LSC

parent ca09ecfe
No related branches found
No related tags found
1 merge request!394Resolve L2SS-868
...@@ -11,18 +11,19 @@ ...@@ -11,18 +11,19 @@
""" """
import numpy
from tango.server import device_property, attribute from tango.server import device_property, attribute
from tango import AttrWriteType from tango import AttrWriteType
from lofar_station_client.statistics.collector import BSTCollector
# Own imports # Own imports
from tangostationcontrol.common.entrypoint import entry from tangostationcontrol.common.entrypoint import entry
from tangostationcontrol.clients.attribute_wrapper import attribute_wrapper from tangostationcontrol.clients.attribute_wrapper import attribute_wrapper
from tangostationcontrol.clients.opcua_client import OPCUAConnection from tangostationcontrol.clients.opcua_client import OPCUAConnection
from tangostationcontrol.clients.statistics.client import StatisticsClient from tangostationcontrol.clients.statistics.client import StatisticsClient
from tangostationcontrol.devices.sdp.statistics import Statistics from tangostationcontrol.devices.sdp.statistics import Statistics
from tangostationcontrol.statistics.collector import BSTCollector
import numpy
__all__ = ["BST", "main"] __all__ = ["BST", "main"]
......
...@@ -15,6 +15,8 @@ ...@@ -15,6 +15,8 @@
from tango.server import device_property, attribute from tango.server import device_property, attribute
from tango import AttrWriteType from tango import AttrWriteType
from lofar_station_client.statistics.collector import XSTCollector
# Additional import # Additional import
from tangostationcontrol.common.entrypoint import entry from tangostationcontrol.common.entrypoint import entry
from tangostationcontrol.clients.attribute_wrapper import attribute_wrapper from tangostationcontrol.clients.attribute_wrapper import attribute_wrapper
...@@ -22,7 +24,6 @@ from tangostationcontrol.clients.opcua_client import OPCUAConnection ...@@ -22,7 +24,6 @@ from tangostationcontrol.clients.opcua_client import OPCUAConnection
from tangostationcontrol.clients.statistics.client import StatisticsClient from tangostationcontrol.clients.statistics.client import StatisticsClient
from tangostationcontrol.devices.sdp.statistics import Statistics from tangostationcontrol.devices.sdp.statistics import Statistics
from tangostationcontrol.statistics.statistics_collector import XSTCollector
import numpy import numpy
......
...@@ -16,7 +16,9 @@ import h5py ...@@ -16,7 +16,9 @@ import h5py
import numpy import numpy
import pytz import pytz
import lofar_station_client.statistics.collector as statistics_collector from lofar_station_client.statistics.collector import BSTCollector
from lofar_station_client.statistics.collector import XSTCollector
from tangostationcontrol.statistics.collector import StationSSTCollector
from lofar_station_client.statistics.packet import SSTPacket, XSTPacket, BSTPacket from lofar_station_client.statistics.packet import SSTPacket, XSTPacket, BSTPacket
...@@ -234,7 +236,7 @@ class sst_hdf5_writer(hdf5_writer): ...@@ -234,7 +236,7 @@ class sst_hdf5_writer(hdf5_writer):
return SSTPacket(packet) return SSTPacket(packet)
def new_collector(self): def new_collector(self):
return statistics_collector.StationSSTCollector() return StationSSTCollector()
def write_values_matrix(self, current_group): def write_values_matrix(self, current_group):
# store the SST values # store the SST values
...@@ -256,7 +258,7 @@ class bst_hdf5_writer(hdf5_writer): ...@@ -256,7 +258,7 @@ class bst_hdf5_writer(hdf5_writer):
return BSTPacket(packet) return BSTPacket(packet)
def new_collector(self): def new_collector(self):
return statistics_collector.BSTCollector() return BSTCollector()
def write_values_matrix(self, current_group): def write_values_matrix(self, current_group):
# store the BST values # store the BST values
...@@ -272,7 +274,7 @@ class xst_hdf5_writer(hdf5_writer): ...@@ -272,7 +274,7 @@ class xst_hdf5_writer(hdf5_writer):
return XSTPacket(packet) return XSTPacket(packet)
def new_collector(self): def new_collector(self):
return statistics_collector.XSTCollector() return XSTCollector()
def next_filename(self, timestamp): def next_filename(self, timestamp):
time_str = str(timestamp.strftime("%Y-%m-%d-%H-%M-%S")) time_str = str(timestamp.strftime("%Y-%m-%d-%H-%M-%S"))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment