From 9d922cd67821d12b8063765dc92bea69604cd150 Mon Sep 17 00:00:00 2001
From: Julian lechner <j.lechner@sobit.at>
Date: Thu, 1 Oct 2026 13:27:54 +0200
Subject: [PATCH] fix(retrieval): run in-process when pipes are forbidden

The Codex sandbox on Windows denies the pipes that the daemon and worker
process use, so searches waited 120 seconds and then failed. Detect that and
run the search in-process.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
---
 scripts/tests/test-retrieval-server.py |  7 +++++++
 shared/retrieval/server.py             | 19 ++++++++++++++++++-
 2 files changed, 25 insertions(+), 1 deletion(-)

diff --git a/scripts/tests/test-retrieval-server.py b/scripts/tests/test-retrieval-server.py
index d19626a..f6d3200 100644
--- a/scripts/tests/test-retrieval-server.py
+++ b/scripts/tests/test-retrieval-server.py
@@ -133,6 +133,13 @@ class RetrievalServerTests(unittest.TestCase):
                 self.assertNotEqual(MODULE.daemon_address(data_dir), old_address)
                 self.assertNotEqual(MODULE.daemon_lock_path(data_dir), old_lock)
 
+    def test_run_direct_runs_in_process_when_pipes_are_forbidden(self):
+        def action(action, root, data_dir, model_cache, query, top_k, output):
+            output.put((True, [query, top_k]))
+
+        with patch.object(MODULE, 'pipes_available', return_value=False), patch.object(MODULE, 'run_action', action):
+            self.assertEqual(MODULE.run_direct('search', Path('.'), Path('.'), Path('.'), 'two words', 3), ['two words', 3])
+
     def test_model_kwargs_use_bfloat16_only_on_supporting_gpus(self):
         bfloat16 = object()
         for available, supported, expected in [(True, True, {'dtype': bfloat16}), (True, False, {}), (False, True, {})]:
diff --git a/shared/retrieval/server.py b/shared/retrieval/server.py
index 7a392a3..0678aa4 100644
--- a/shared/retrieval/server.py
+++ b/shared/retrieval/server.py
@@ -11,6 +11,7 @@ import multiprocessing
 from multiprocessing import AuthenticationError
 from multiprocessing.connection import Client, Listener
 import os
+import queue
 from pathlib import Path
 import re
 import sqlite3
@@ -573,7 +574,23 @@ class Index:
             return result
 
 
+def pipes_available() -> bool:
+    """Sandboxes such as Codex on Windows forbid the pipes that the daemon and worker process need."""
+    try:
+        first, second = multiprocessing.Pipe()
+    except PermissionError:
+        return False
+    first.close()
+    second.close()
+    return True
+
+
 def run_direct(action: str, root: Path, data_dir: Path, model_cache: Path, query: str | None, top_k: int):
+    if not pipes_available():
+        # ponytail: in-process fallback has no worker timeout; the client's own command timeout still applies.
+        output = queue.Queue(1)
+        run_action(action, root, data_dir, model_cache, query, top_k, output)
+        return output.get()[1]
     output = multiprocessing.Queue(1)
     worker = multiprocessing.Process(target=run_action, args=(action, root, data_dir, model_cache, query, top_k, output))
     worker.start()
@@ -614,7 +631,7 @@ def main():
         parser.error("search requires --query")
     root = args.root.resolve()
     data_dir.mkdir(parents=True, exist_ok=True)
-    result = try_daemon(root, data_dir, model_cache, args.action, args.query, args.top_k)
+    result = try_daemon(root, data_dir, model_cache, args.action, args.query, args.top_k) if pipes_available() else None
     if result is None:
         result = run_direct(args.action, root, data_dir, model_cache, args.query, args.top_k)
     print(json.dumps(result, ensure_ascii=False))