changes

tangostationcontrol/tangostationcontrol/statistics/reader.py

@@ -274,6 +274,8 @@ def main():
     # set up everything
     stat_parser = setup_stat_parser()
 
+    logger.debug("test")
+
     # get a single numpy array of all the statistics stored.
     array = stat_parser.collect_values()
     logger.debug(f"Collected the statistics values of {stat_parser.get_statistics_count()} statistics in to one gaint array of shape: {array.shape} and type: {array.dtype}")
@@ -281,3 +283,6 @@ def main():
     # Get a list of all the statistics timestamps we have
     statistics = stat_parser.list_statistics()
     logger.debug(f"These are all the statistics parsed: {statistics}")
+
+    for i in array:
+        logger.debug(i.rcu_attenuator_dB)
\ No newline at end of file

tangostationcontrol/tangostationcontrol/statistics/writer/hdf5.py

@@ -24,7 +24,7 @@ from lofar_station_client.statistics.packet import BSTPacket
 from lofar_station_client.statistics.packet import SSTPacket
 from lofar_station_client.statistics.packet import XSTPacket
 
-from tango import DeviceProxy
+from tango import DeviceProxy, exception
 
 logger = logging.getLogger("statistics_writer")
 
@@ -310,37 +310,41 @@ class SstHdf5Writer(HDF5Writer):
             ].astype(numpy.float32),
             compression="gzip",
         )
+
+        try:
             try:
+                rcu_attenuator_dB_data = self.current_matrix.parameters["rcu_attenuator_dB"].astype(numpy.int64)
+            except:
+                rcu_attenuator_dB_data = None
+
             current_group.create_dataset(
                 name="rcu_attenuator_dB",
-                data=self.current_matrix.parameters["rcu_attenuator_dB"].astype(
-                    numpy.int64
-                ),
+                data=rcu_attenuator_dB_data,
                 compression="gzip",
             )
-        except:
-            pass
+
             try:
+                rcu_band_select_data = self.current_matrix.parameters["rcu_band_select"].astype(numpy.int64)
+            except:
+                rcu_band_select_data = None
+
             current_group.create_dataset(
                 name="rcu_band_select",
-                data=self.current_matrix.parameters["rcu_band_select"].astype(
-                    numpy.int64
-                ),
+                data=rcu_band_select_data,
                 compression="gzip",
             )
-        except:
-            pass
+
             try:
+                rcu_dth_on_data = self.current_matrix.parameters["rcu_dth_on"].astype(numpy.bool_)
+            except:
+                rcu_dth_on_data = None
+
             current_group.create_dataset(
                 name="rcu_dth_on",
-                data=self.current_matrix.parameters["rcu_dth_on"].astype(
-                    numpy.bool_
-                ),
+                data=rcu_dth_on_data,
                 compression="gzip",
             )
-        except:
-            pass
-        try:
+
         except AttributeError as e:
             logger.warning("AttributeError: Device values not written.")
         except Exception as e: