Fix stale event loop + .env loading

src/passage_entity/benchmark_runner.py

@@ -79,17 +79,24 @@ from src.passage_entity.utils import QuerySolution
 # ---------------------------------------------------------------------------
 from openai import AsyncOpenAI
 
-# Shared client — avoids "Event loop is closed" errors from abandoned clients
-_openai_clients: dict = {}
-
+# Load .env file if present (for API keys)
+_dotenv_path = os.path.join(os.path.dirname(__file__), "..", "..", ".env")
+if os.path.isfile(_dotenv_path):
+    with open(_dotenv_path) as _f:
+        for _line in _f:
+            _line = _line.strip()
+            if _line and not _line.startswith("#") and "=" in _line:
+                _k, _v = _line.split("=", 1)
+                _v = _v.strip().strip('"').strip("'")
+                if _k.strip() not in os.environ:
+                    os.environ[_k.strip()] = _v
+
+# Create a fresh client per call — avoids stale event loop issues
 def _get_client(base_url="https://api.openai.com/v1", api_key=""):
-    key = (base_url, api_key)
-    if key not in _openai_clients:
-        _openai_clients[key] = AsyncOpenAI(
-            base_url=base_url,
-            api_key=api_key or os.environ.get("OPENAI_API_KEY", ""),
-        )
-    return _openai_clients[key]
+    return AsyncOpenAI(
+        base_url=base_url,
+        api_key=api_key or os.environ.get("OPENAI_API_KEY", ""),
+    )
 
 async def _openai_complete(model, prompt, system_prompt=None, history_messages=[],
                            base_url="https://api.openai.com/v1", api_key="", **kwargs):