Sea action health check

scos_actions/actions/acquire_sea_data_product.py

@@ -56,7 +56,7 @@
     convert_linear_to_dB,
     convert_watts_to_dBm,
 )
-from scos_actions.signals import measurement_action_completed
+from scos_actions.signals import measurement_action_completed, trigger_api_restart
 
 logger = logging.getLogger(__name__)
 
@@ -570,6 +570,10 @@ def test_required_components(self):
         if "SPU X410" not in [s.name for s in switches.values()]:
             msg = "Configuration error: no switch configured with name 'SPU X410'"
             raise RuntimeError(msg)
+        if not self.sigan.healthy():
+            trigger_api_restart.send(
+                sender=self.__class__
+            )
         # TODO: Add additional health checks
         return None
 

scos_actions/actions/interfaces/action.py

@@ -38,9 +38,10 @@ def __init__(self, parameters, sigan, gps=None):
         self.sigan = sigan
         self.gps = gps
         self.sensor_definition = capabilities["sensor"]
-        self.has_preselector = (
-            True if "preselector" in self.sensor_definition else False
-        )
+        if "preselector" in self.sensor_definition and "rf_paths" in self.sensor_definition["preselector"]:
+            self.has_configurable_preselector = True
+        else:
+            self.has_configurable_preselector = False
 
     def configure(self, measurement_params: dict):
         self.configure_sigan(measurement_params)
@@ -59,7 +60,7 @@ def configure_preselector(self, measurement_params: dict):
             path = measurement_params[self.PRESELECTOR_PATH_KEY]
             logger.debug(f"Setting preselector RF path: {path}")
             preselector.set_state(path)
-        elif self.has_preselector:
+        elif self.has_configurable_preselector:
             # Require the RF path to be specified if the sensor has a preselector.
             raise ParameterException(
                 f"No {self.PRESELECTOR_PATH_KEY} value specified in the YAML config."

scos_actions/metadata/sigmf_builder.py

@@ -157,7 +157,7 @@ def set_capture(
             "core:datetime": capture_time,
         }
         # Add extra information to capture
-        capture_md.update(extra_entries)
+        if extra_entries: capture_md.update(extra_entries)
 
         self.sigmf_md.add_capture(sample_start, metadata=capture_md)