fix: bound the waits that could freeze the learn loop (tests/test_voyager_skillmanager_bounds.py)

tests/test_voyager_skillmanager_bounds.py

@@ -46,6 +46,32 @@ def check(label: str, condition: bool, detail: str = "", skip: bool = False) ->
         FAILURES.append(label)
 
 
+def _executor_join_absent(helpers: str) -> bool:
+    """True when no LIVE line joins a worker or awaits a future.
+
+    The helper docstrings name `ThreadPoolExecutor` and `shutdown(wait=True)`
+    on purpose, to warn the next reader off them. A substring search therefore
+    reports the opposite of the truth. Strip string literals and look at the
+    code that actually runs.
+    """
+    try:
+        tree = ast.parse("class _Probe:\n" + "\n".join(
+            "    " + line for line in helpers.splitlines()))
+    except SyntaxError:
+        return False
+    spans = [
+        (node.lineno, node.end_lineno)
+        for node in ast.walk(tree)
+        if isinstance(node, ast.Constant) and isinstance(node.value, str)
+    ]
+    for i, line in enumerate(helpers.splitlines(), 1):
+        if any(a <= i <= b for a, b in spans):
+            continue
+        if "shutdown(wait" in line or "future.result" in line:
+            return False
+    return True
+
+
 def _patch_literals() -> dict[str, str]:
     """Pull the string constants the skill patch is built from."""
     source = (ROOT / "voyager_stack.py").read_text(encoding="utf-8")
@@ -94,8 +120,15 @@ def main() -> None:
     check("bloco de helpers existe", bool(helpers))
     check("VECTORDB_OPEN_SECONDS definido", "VECTORDB_OPEN_SECONDS" in helpers)
     check(
-        "a abertura roda em worker com future.result(timeout=...)",
-        "future.result(timeout=self.VECTORDB_OPEN_SECONDS)" in helpers,
+        "a abertura roda em thread daemon sob deadline",
+        "_open_with_deadline" in helpers and "daemon=True" in helpers,
+    )
+    check(
+        "o deadline nao faz join no worker que travou",
+        # Nao basta procurar a substring: o docstring do helper cita
+        # `shutdown(wait=True)` e `ThreadPoolExecutor` justamente para avisar
+        # contra eles. Grep daria falso positivo; olhamos so o codigo vivo.
+        _executor_join_absent(helpers),
     )
     check(
         "o timeout vira RuntimeError (o runner pode retentar)",