Merge branch 'master' of https://github.com/NTIA/scos-actions into ca…

…librate_to_antenna

scos_actions/actions/acquire_sea_data_product.py

@@ -79,9 +79,6 @@
 env = Env()
 logger = logging.getLogger(__name__)
 
-if not ray.is_initialized():
-    # Dashboard is only enabled if ray[default] is installed
-    ray.init()
 
 # Define parameter keys
 RF_PATH = "rf_path"
@@ -507,6 +504,13 @@ def __call__(self, sensor: Sensor, schedule_entry: dict, task_id: int):
         """This is the entrypoint function called by the scheduler."""
         self._sensor = sensor
         action_start_tic = perf_counter()
+        # Ray should have already been initialized within scos-sensor,
+        # but check and initialize just in case.
+        if not ray.is_initialized():
+            logger.info("Initializing ray.")
+            logger.info("Set RAY_INIT=true to avoid initializing within " + __name__)
+            # Dashboard is only enabled if ray[default] is installed
+            ray.init()
 
         _ = psutil.cpu_percent(interval=None)  # Initialize CPU usage monitor
         self.test_required_components()

scos_actions/actions/runtime_error_action.py

@@ -0,0 +1,28 @@
+"""A simple example action that raises a RuntimeError."""
+
+import logging
+from typing import Optional
+
+from scos_actions.actions.interfaces.action import Action
+from scos_actions.hardware.sensor import Sensor
+
+logger = logging.getLogger(__name__)
+
+
+class RuntimeErrorAction(Action):
+    """
+    Raise a runtime error.
+    This is useful for testing and debugging. Note: this action
+    is currently not loaded in any scenario and must be manually
+    added to use.
+
+    """
+
+    def __init__(self):
+        super().__init__(parameters={"name": "RuntimeErrorAction"})
+
+    def __call__(self, sensor: Optional[Sensor], schedule_entry: dict, task_id: int):
+        msg = "Raising RuntimeError {name}/{tid}"
+        schedule_entry_name = schedule_entry["name"]
+        logger.log(msg=msg.format(name=schedule_entry_name, tid=task_id))
+        raise RuntimeError("RuntimeError from RuntimeErrorAction")

scos_actions/actions/system_exit_action.py

@@ -0,0 +1,28 @@
+"""A simple action that raises SystemExit"""
+
+import logging
+from typing import Optional
+
+from scos_actions.actions.interfaces.action import Action
+from scos_actions.hardware.sensor import Sensor
+
+logger = logging.getLogger(__name__)
+
+
+class SystemExitAction(Action):
+    """
+    Raise a SystemExit.
+    This is useful for testing and debugging. Note: this action
+    is currently not loaded in any scenario and must be manually
+    added to use.
+
+    """
+
+    def __init__(self):
+        super().__init__(parameters={"name": "SystemExitAction"})
+
+    def __call__(self, sensor: Optional[Sensor], schedule_entry: dict, task_id: int):
+        msg = "Raising SystemExit {name}/{tid}"
+        schedule_entry_name = schedule_entry["name"]
+        logger.log(msg=msg.format(name=schedule_entry_name, tid=task_id))
+        raise SystemExit("SystemExit produced by SystemExitAction. ")

scos_actions/discover/__init__.py

@@ -5,7 +5,9 @@
 from scos_actions.discover.yaml import load_from_yaml
 from scos_actions.settings import ACTION_DEFINITIONS_DIR
 
-actions = {"logger": Logger()}
+actions = {
+    "logger": Logger(),
+}
 test_actions = {
     "test_sync_gps": SyncGps(parameters={"name": "test_sync_gps"}),
     "test_monitor_sigan": MonitorSignalAnalyzer(