GUI app (experimental) (#730)

* add default config * first pass * flake8 * cleanup * first pass at using qthreads * cleanup * WIP * better error handling * improved UI * bugfix * fix merge bugs * import order * cleanup * make gui requirements optional * pr review requested changes * Update server/gui/main.py Co-Authored-By: csweaver <charlottesweaver@gmail.com> * pr review request * qt child class methods -> camelCase * whitespace
2026-10-07 08:48:11 +08:00 · 2019-04-30 12:52:15 -07:00
parent ea187f48e0
commit 9f10d8095a
10 changed files with 407 additions and 17 deletions
@@ -0,0 +1,51 @@
+import traceback
+
+from PyQt5.QtCore import QRunnable, pyqtSlot
+
+from server.gui.utils import WorkerSignals
+
+
+class DataLoadWorker(QRunnable):
+    def __init__(self, data_file, layout="umap", *args, **kwargs):
+        super(DataLoadWorker, self).__init__()
+        self.data_file = data_file
+        self.layout = layout
+        self.signals = WorkerSignals()
+
+    @pyqtSlot()
+    def run(self):
+        if not self.data_file:
+            self.signals.finished.emit()
+            return
+
+        # delayed import to speed load
+        from server.app.scanpy_engine.scanpy_engine import ScanpyEngine
+        args = {
+            "layout": self.layout,
+            "diffexp": "ttest",
+            "max_category_items": 100,
+            "diffexp_lfc_cutoff": 0.01,
+            "obs_names": None,
+            "var_names": None,
+        }
+        try:
+            data_results = ScanpyEngine(self.data_file, args)
+        except Exception as e:
+            traceback.print_exc()
+            self.signals.error.emit(str(e))
+        else:
+            self.signals.result.emit(data_results)
+        finally:
+            self.signals.finished.emit()
+
+
+class ServerRunWorker(QRunnable):
+    def __init__(self, app, host, port, *args, **kwargs):
+        super(ServerRunWorker, self).__init__()
+        self.app = app
+        self.host = host
+        self.port = port
+
+    @pyqtSlot()
+    def run(self):
+        self.app.run(host=self.host, debug=False, port=self.port, threaded=True)