mcp-server/src/legal_mcp/services/appraiser_facts_extractor.py

@@ -103,7 +103,7 @@ async def extract_facts_from_document(
             f"שמאי: {appraiser_name}{chunk_label}\n\n"
             f"--- תחילת שומה ---\n{chunk}\n--- סוף שומה ---"
         )
-        result = await claude_session.query_json(prompt)
+        result = await claude_session.query_json(prompt, tools="")  # no tool_use → no error_max_turns
         if not isinstance(result, list):
             logger.warning(
                 "extract_facts_from_document: chunk %d returned non-list (%s) for doc=%s",

mcp-server/src/legal_mcp/services/argument_aggregator.py

@@ -147,7 +147,7 @@ async def _aggregate_party(
     prompt = _build_prompt(party, propositions)
 
     try:
-        raw_result = await claude_session.query_json(prompt)
+        raw_result = await claude_session.query_json(prompt, tools="")  # no tool_use → no error_max_turns
     except RuntimeError as e:
         # Surface CLI-unavailable specifically so the caller can report
         # cleanly instead of crashing the whole job.

mcp-server/src/legal_mcp/services/brainstorm.py

@@ -134,7 +134,7 @@ async def generate_directions(
 {doc_context or '(אין מסמכים בתיק)'}
 """
 
-    result = await claude_session.query_json(user_content)
+    result = await claude_session.query_json(user_content, tools="")  # no tool_use → no error_max_turns
     if result is None:
         logger.warning("Failed to parse brainstorm response")
         return {

mcp-server/src/legal_mcp/services/claims_extractor.py

@@ -135,7 +135,7 @@ async def _extract_chunk(
     last_err: Exception | None = None
     for attempt in range(CHUNK_RETRY_ATTEMPTS + 1):
         try:
-            claims = await claude_session.query_json(prompt)
+            claims = await claude_session.query_json(prompt, tools="")  # no tool_use → no error_max_turns
         except Exception as e:
             last_err = e
             logger.warning(

mcp-server/src/legal_mcp/services/corroboration.py

@@ -88,6 +88,7 @@ async def classify_treatment(cited_citation: str, context: str) -> str:
             user, system=_TREATMENT_PROMPT,
             model=config.HALACHA_EXTRACT_MODEL or None,
             effort=config.HALACHA_EXTRACT_EFFORT or None,
+            tools="",  # pure text→JSON — no tool_use → no error_max_turns
         )
     except Exception as e:
         logger.warning("classify_treatment failed: %s", e)

mcp-server/src/legal_mcp/services/halacha_extractor.py

@@ -309,6 +309,7 @@ async def _nli_check(items: list[dict]) -> list[str]:
             system=halacha_quality.NLI_SYSTEM,
             model=config.HALACHA_NLI_MODEL or None,
             effort=config.HALACHA_NLI_EFFORT or None,
+            tools="",  # pure text→JSON — no tool_use → no error_max_turns
         )
     except Exception as e:
         logger.warning("halacha NLI check failed (fail-open, no flags): %s", e)
@@ -352,6 +353,7 @@ async def _consolidate_precedent(case_law_id: UUID) -> int:
             system=halacha_quality.CONSOLIDATE_SYSTEM,
             model=config.HALACHA_CONSOLIDATE_MODEL or None,
             effort=config.HALACHA_CONSOLIDATE_EFFORT or None,
+            tools="",  # pure text→JSON — no tool_use → no error_max_turns
         )
         groups = halacha_quality.parse_fold_groups(raw)
         if not groups:
@@ -423,6 +425,7 @@ async def _extract_chunk(
                 system=base_prompt,
                 model=config.HALACHA_EXTRACT_MODEL or None,
                 effort=(effort or config.HALACHA_EXTRACT_EFFORT) or None,
+                tools="",  # pure text→JSON — no tool_use → no error_max_turns
             )
         except Exception as e:
             last_err = e

mcp-server/src/legal_mcp/services/learning_loop.py

@@ -89,7 +89,7 @@ async def analyze_changes(draft_text: str, final_text: str) -> dict:
 --- גרסה סופית ---
 {final_sample}
 """
-    result = await claude_session.query_json(prompt)
+    result = await claude_session.query_json(prompt, tools="")  # no tool_use → no error_max_turns
     if result is None:
         logger.warning("Failed to parse lessons response")
         return {"changes": [], "new_expressions": [], "overall_assessment": ""}

mcp-server/src/legal_mcp/services/qa_validator.py

@@ -154,7 +154,7 @@ async def check_claims_coverage(blocks: list[dict], claims: list[dict], outcome:
 ## בלוק הדיון:
 {discussion}"""
 
-    parsed = await claude_session.query_json(prompt)
+    parsed = await claude_session.query_json(prompt, tools="")  # no tool_use → no error_max_turns
     if parsed is None:
         logger.warning("Failed to parse claims check")
         # Fallback: assume all covered (don't block export on parse failure)

mcp-server/src/legal_mcp/services/style_metadata_extractor.py

@@ -119,7 +119,7 @@ async def extract_decision_metadata(corpus_id: UUID | str) -> dict:
     )
 
     try:
-        result = await claude_session.query_json(user_msg, system=METADATA_PROMPT)
+        result = await claude_session.query_json(user_msg, system=METADATA_PROMPT, tools="")  # no tool_use → no error_max_turns
     except Exception as e:
         logger.warning("style_metadata_extractor: query failed: %s", e)
         return {}