updated app.py

Author: subCode321

app.py

@@ -1,36 +1,79 @@
 import streamlit as st
 from pathlib import Path
 import json
+import subprocess
+import sys
+import os
+import atexit
+import signal
 # For some reason the windows version only works if this is imported here
 import pyopenms
 
+# Start RQ worker as a background process
+def start_rq_worker():
+    if sys.platform == "win32":
+        # Windows needs different handling for background processes
+        worker_process = subprocess.Popen(
+            ["rq", "worker", "--with-scheduler", "-q", "mzml_workflow_run"],
+            creationflags=subprocess.CREATE_NEW_PROCESS_GROUP
+        )
+    else:
+        # Unix-based systems
+        worker_process = subprocess.Popen(
+            ["rq", "worker", "--with-scheduler", "-q", "mzml_workflow_run"],
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE,
+            start_new_session=True  # This creates a new process group
+        )
+    
+    # Register function to terminate worker when app exits
+    def cleanup():
+        print("Shutting down RQ worker...")
+        if sys.platform == "win32":
+            worker_process.send_signal(signal.CTRL_BREAK_EVENT)
+        else:
+            try:
+                os.killpg(os.getpgid(worker_process.pid), signal.SIGTERM)
+            except:
+                worker_process.terminate()
+    
+    atexit.register(cleanup)
+    return worker_process
+
+# Initialize settings
 if "settings" not in st.session_state:
-        with open("settings.json", "r") as f:
-            st.session_state.settings = json.load(f)
+    with open("settings.json", "r") as f:
+        st.session_state.settings = json.load(f)
+
+# Start RQ worker
+print("Starting RQ worker...")
+worker_process = start_rq_worker()
+print("RQ worker started")
 
-if __name__ == '__main__':
-    pages = {
-        str(st.session_state.settings["app-name"]) : [
-            st.Page(Path("content", "quickstart.py"), title="Quickstart", icon="👋"),
-            st.Page(Path("content", "documentation.py"), title="Documentation", icon="📖"),
-        ],
-        "TOPP Workflow Framework": [
-            st.Page(Path("content", "topp_workflow_file_upload.py"), title="File Upload", icon="📁"),
-            st.Page(Path("content", "topp_workflow_parameter.py"), title="Configure", icon="⚙️"),
-            st.Page(Path("content", "topp_workflow_execution.py"), title="Run", icon="🚀"),
-            st.Page(Path("content", "topp_workflow_results.py"), title="Results", icon="📊"),
-        ],
-        "pyOpenMS Workflow" : [
-            st.Page(Path("content", "file_upload.py"), title="File Upload", icon="📂"),
-            st.Page(Path("content", "raw_data_viewer.py"), title="View MS data", icon="👀"),
-            st.Page(Path("content", "run_example_workflow.py"), title="Run Workflow", icon="⚙️"),
-            st.Page(Path("content", "download_section.py"), title="Download Results", icon="⬇️"),
-        ],
-        "Others Topics": [
-            st.Page(Path("content", "simple_workflow.py"), title="Simple Workflow", icon="⚙️"),
-            st.Page(Path("content", "run_subprocess.py"), title="Run Subprocess", icon="🖥️"),
-        ]
-    }
+# Set up page configuration
+pages = {
+    str(st.session_state.settings["app-name"]) : [
+        st.Page(Path("content", "quickstart.py"), title="Quickstart", icon="👋"),
+        st.Page(Path("content", "documentation.py"), title="Documentation", icon="📖"),
+    ],
+    "TOPP Workflow Framework": [
+        st.Page(Path("content", "topp_workflow_file_upload.py"), title="File Upload", icon="📁"),
+        st.Page(Path("content", "topp_workflow_parameter.py"), title="Configure", icon="⚙️"),
+        st.Page(Path("content", "topp_workflow_execution.py"), title="Run", icon="🚀"),
+        st.Page(Path("content", "topp_workflow_results.py"), title="Results", icon="📊"),
+    ],
+    "pyOpenMS Workflow" : [
+        st.Page(Path("content", "file_upload.py"), title="File Upload", icon="📂"),
+        st.Page(Path("content", "raw_data_viewer.py"), title="View MS data", icon="👀"),
+        st.Page(Path("content", "run_example_workflow.py"), title="Run Workflow", icon="⚙️"),
+        st.Page(Path("content", "download_section.py"), title="Download Results", icon="⬇️"),
+    ],
+    "Others Topics": [
+        st.Page(Path("content", "simple_workflow.py"), title="Simple Workflow", icon="⚙️"),
+        st.Page(Path("content", "run_subprocess.py"), title="Run Subprocess", icon="🖥️"),
+    ]
+}
 
-    pg = st.navigation(pages)
-    pg.run()
+# Run the Streamlit app
+pg = st.navigation(pages)
+pg.run()