Full implementation

src/hal/actor/commands/abort_exposures.py

@@ -8,14 +8,16 @@
 
 from __future__ import annotations
 
+import asyncio
+
 from typing import TYPE_CHECKING
 
 from . import hal_command_parser
 
 
 if TYPE_CHECKING:
-
-    from .. import HALCommandType
+    from hal.actor import HALCommandType
+    from hal.macros.expose import ExposeMacro
 
 
 __all__ = ["abort_exposures"]
@@ -25,12 +27,28 @@
 async def abort_exposures(command: HALCommandType):
     """Aborts ongoing exposures.."""
 
-    if command.actor.observatory == "APO":
-        return command.fail("abort-exposures is not supported for APO.")
+    expose_macro = command.actor.helpers.macros["expose"]
+    assert isinstance(expose_macro, ExposeMacro)
+
+    if expose_macro.running:
+        command.warning("Cancelling the expose macro.")
+        expose_macro.cancel(now=True)
+
+    command.warning("Aborting ongoing exposures.")
 
     tasks = [
         command.actor.helpers.apogee.abort(command),
         command.actor.helpers.boss.abort(command),
     ]
 
-    return command.finish()
+    results = await asyncio.gather(*tasks, return_exceptions=True)
+    for iresult, result in enumerate(results):
+        instrument = ["APOGEE", "BOSS"][iresult]
+        if isinstance(result, Exception):
+            return command.fail(f"Failed to abort {instrument} exposure: {result!s}")
+        elif result is not True:
+            return command.fail(f"Unkown error while aborting {instrument} exposure.")
+        else:
+            continue
+
+    return command.finish(text="Exposures have been aborted.")

src/hal/helpers/apogee.py

@@ -311,6 +311,8 @@ async def abort(self, command: HALCommandType):
 
         await self._send_command(command, "apogee", "stop", time_limit=60)
 
+        return True
+
 
 class APOGEEGangHelper:
     """Helper for the APOGEE gang connector."""

src/hal/helpers/boss.py

@@ -252,10 +252,14 @@ async def readout(self, command: HALCommandType):
     async def abort(self, command: HALCommandType):
         """Aborts the ongoing exposure."""
 
-        if not self.actor.observatory == "LCO":
-            raise ValueError("abort is not supported at APO.")
-
         if not self.is_exposing():
+            command.warning("No exposure to abort.")
             return True
 
-        await self._send_command(command, "apogee", "abort", time_limit=60)
+        if self.actor.observatory == "LCO":
+            await self._send_command(command, "yao", "abort --reset", time_limit=60)
+        else:
+            await self._send_command(command, "boss", "abort", time_limit=60)
+            await self._send_command(command, "boss", "clearExposure", time_limit=30)
+
+        return True