R3.2.8.6-R1.1 Research-Logic Reasoning-Only Recovery

core/pipeline_agent.py

@@ -1272,10 +1272,42 @@ Literature Synthesis:
 {evidence_block}
 {mode_directive}
 Return a concise PROVISIONAL RESEARCH LOGIC CONTRACT in plain English prose. It must guide later sections without fixing an expected result or conclusion. Do not use citations in the contract."""
-        return self.stream_deepseek(
-            sys_prompt, user_prompt, max_tokens=2200,
-            model_role="reasoning", thinking=True, allow_fallback=False,
-        )
+        def _stream_with_reasoning_exhaustion_recovery():
+            try:
+                yield from self.stream_deepseek(
+                    sys_prompt,
+                    user_prompt,
+                    max_tokens=2200,
+                    model_role="reasoning",
+                    thinking=True,
+                    allow_fallback=False,
+                    reasoning_only_recovery=True,
+                )
+                return
+            except DeepSeekReasoningOnlyExhaustionError as exc:
+                logging.warning(
+                    "Research logic reasoning-only exhaustion; retrying once with thinking disabled: %s",
+                    exc,
+                )
+                self._touch_execution_progress("research_logic_direct_recovery")
+
+            recovery_system = (
+                sys_prompt
+                + "\n\nRECOVERY MODE: Produce the final provisional research logic contract directly. "
+                  "Do not perform extended hidden reasoning. Preserve the original topic, literature synthesis, "
+                  "research evidence, uncertainty, evidence-strength boundaries, and mode-specific planning constraints. "
+                  "Do not invent findings, coefficients, causal claims, or facts."
+            )
+            yield from self.stream_deepseek(
+                recovery_system,
+                user_prompt,
+                max_tokens=2200,
+                model_role="reasoning",
+                thinking=False,
+                allow_fallback=False,
+            )
+
+        return _stream_with_reasoning_exhaustion_recovery()
 
     @staticmethod
     def _front_matter_keywords(value, minimum=4, maximum=6):