Run mount probes in parallel to avoid proxy idle timeout

app.py

@@ -1,6 +1,7 @@
 import base64
 import socket
 import time
+from concurrent.futures import ThreadPoolExecutor, as_completed
 from datetime import datetime, timezone
 
 import gradio as gr
@@ -76,19 +77,27 @@ def run_checks():
         "|---|-------|------|-----------:|-------------:|--------|",
     ]
 
-    yield f"{header}\n\n⏳ Probing {len(MOUNTS)} mount points (~{READ_SECONDS}s each)…"
-
-    rows = []
-    for i, (mount_id, name) in enumerate(MOUNTS, 1):
-        r = probe_mount(mount_id, USER, PASS)
-        icon = ICON.get(r["status"], "?")
-        rows.append(
-            f"| {icon} | `{mount_id}` | {name} | {r['bytes']} | {r['rtcm']} | {r['detail']} |"
-        )
-        partial = "\n".join([header, "", *table_header, *rows])
-        if i < len(MOUNTS):
-            partial += f"\n\n⏳ {i}/{len(MOUNTS)} done, probing next…"
-        yield partial
+    yield f"{header}\n\n⏳ Probing {len(MOUNTS)} mount points in parallel (~{READ_SECONDS}s)…"
+
+    rows_by_idx: dict[int, str] = {}
+    with ThreadPoolExecutor(max_workers=len(MOUNTS)) as ex:
+        futures = {
+            ex.submit(probe_mount, mount_id, USER, PASS): (i, mount_id, name)
+            for i, (mount_id, name) in enumerate(MOUNTS)
+        }
+        for future in as_completed(futures):
+            i, mount_id, name = futures[future]
+            r = future.result()
+            icon = ICON.get(r["status"], "?")
+            rows_by_idx[i] = (
+                f"| {icon} | `{mount_id}` | {name} | "
+                f"{r['bytes']} | {r['rtcm']} | {r['detail']} |"
+            )
+            ordered = [rows_by_idx[j] for j in sorted(rows_by_idx)]
+            partial = "\n".join([header, "", *table_header, *ordered])
+            if len(rows_by_idx) < len(MOUNTS):
+                partial += f"\n\n⏳ {len(rows_by_idx)}/{len(MOUNTS)} done…"
+            yield partial
 
 
 DARK_THEME = gr.themes.Base(