Allow analysis to be turned off via a query parameter

Author: d-j-hatton

src/murfey/instrument_server/api.py

@@ -186,9 +186,13 @@ def setup_multigrid_watcher(
 
 
 @router.post("/sessions/{session_id}/start_multigrid_watcher")
-def start_multigrid_watcher(session_id: MurfeySessionID):
+def start_multigrid_watcher(session_id: MurfeySessionID, process: bool = True):
     if watchers.get(session_id) is None:
         return {"success": False}
+    if not process:
+        watchers[session_id]._listeners = [
+            partial(watchers[session_id]._listeners[0], analyse=False)
+        ]
     watchers[session_id].start()
     return {"success": True}
 

src/murfey/server/api/instrument.py

@@ -140,7 +140,9 @@ async def setup_multigrid_watcher(
 
 
 @router.post("/sessions/{session_id}/start_multigrid_watcher")
-async def start_multigrid_watcher(session_id: MurfeySessionID, db=murfey_db):
+async def start_multigrid_watcher(
+    session_id: MurfeySessionID, process: bool = True, db=murfey_db
+):
     data = {}
     instrument_name = (
         db.exec(select(Session).where(Session.id == session_id)).one().instrument_name
@@ -151,7 +153,7 @@ async def start_multigrid_watcher(session_id: MurfeySessionID, db=murfey_db):
     if machine_config.instrument_server_url:
         async with aiohttp.ClientSession() as clientsession:
             async with clientsession.post(
-                f"{machine_config.instrument_server_url}/sessions/{session_id}/start_multigrid_watcher",
+                f"{machine_config.instrument_server_url}/sessions/{session_id}/start_multigrid_watcher?process={'true' if process else 'false'}",
                 headers={
                     "Authorization": f"Bearer {instrument_server_tokens[session_id]['access_token']}"
                 },