Notifications and stopfiles

rt_eqcorrscan/config/mailer.py

@@ -1,6 +1,7 @@
 """ Basic notification handling. Only tested for pushover """
 
 import logging
+import platform
 
 from notifiers import get_notifier
 
@@ -18,6 +19,7 @@ def __init__(
         self.default_args = default_args
 
     def notify(self, content: str):
+        content = f"RTEQcorrscan message from {platform.node()}: {content}"
         try:
             self.service.notify(message=content, **self.default_args)
         except Exception as e:

rt_eqcorrscan/rt_match_filter.py

@@ -1215,7 +1215,7 @@ def backfill(
         Logger.info("Backfill process started, returning")
         return
 
-    def stop(self, write_stopfile: bool = False) -> None:
+    def stop(self, write_stopfile: bool = True) -> None:
         """
         Stop the real-time system.
        
@@ -1225,6 +1225,7 @@ def stop(self, write_stopfile: bool = False) -> None:
             Used to write a one-line file telling listening systems that
             this has stopped. Used by the Reactor.
         """
+        self.notifier.notify("Stopping run")
         if self.plotter is not None:  # pragma: no cover
             self.plotter.background_stop()
         self.rt_client.background_stop()