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

…A-178_test_actions_loading

scos_actions/__init__.py

@@ -1 +1 @@
-__version__ = "8.0.0"
+__version__ = "8.0.1"

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"
@@ -509,6 +506,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. ")