Allow concurrent search jobs

application_neo4j/README.md

@@ -130,3 +130,18 @@ Lors de son lancement, le Space charge un export de la base de données neo4j de
 
 Puisque le dataset est privé sur Hugging Face, le Space utilise un secret `HF_TOKEN` qui donne accès en lecture au dataset.
 
+### Recherches simultanées
+
+L'application accepte par défaut deux recherches simultanées. Chaque recherche
+conserve son propre identifiant, son état de progression et son résultat. Les
+requêtes supplémentaires restent dans l'état `queued` jusqu'à ce qu'un worker
+soit disponible.
+
+Le nombre de recherches simultanées peut être configuré avec la variable
+d'environnement `SEARCH_MAX_WORKERS`. La valeur doit être un entier strictement
+positif ; une valeur absente ou invalide utilise la valeur par défaut `2`.
+
+La création initiale des projections GDS reste sérialisée afin que deux
+requêtes arrivant au démarrage ne tentent pas de créer le même graphe. Une fois
+les projections disponibles, les BFS et la construction de leurs résultats
+s'exécutent indépendamment.

application_neo4j/app.py

@@ -24,10 +24,29 @@ NEO4J_URI = "bolt://localhost:7687"
 GDS_GRAPH_NAME = "genealogie_gds"
 SEARCH_JOB_TTL_SECONDS = 60 * 60
 RESULT_BATCH_SIZE = 25
+DEFAULT_SEARCH_MAX_WORKERS = 2
 
-# A single worker prevents CPU-heavy GDS searches from competing on the
-# cpu-basic Space. Additional requests remain visible with the "queued" stage.
-search_executor = ThreadPoolExecutor(max_workers=1, thread_name_prefix="search")
+
+def positive_int_env(name, default):
+    """Read a strictly positive integer setting, falling back safely."""
+    try:
+        value = int(os.environ.get(name, default))
+    except (TypeError, ValueError):
+        return default
+    return value if value > 0 else default
+
+
+# Neo4j's driver and the projected GDS graphs support concurrent read jobs.
+# Keep the pool bounded because every BFS is CPU- and memory-intensive. Jobs
+# beyond this limit remain visible in the existing "queued" stage.
+SEARCH_MAX_WORKERS = positive_int_env(
+    "SEARCH_MAX_WORKERS",
+    DEFAULT_SEARCH_MAX_WORKERS,
+)
+search_executor = ThreadPoolExecutor(
+    max_workers=SEARCH_MAX_WORKERS,
+    thread_name_prefix="search",
+)
 search_jobs = {}
 search_jobs_lock = Lock()
 graph_projection_lock = Lock()