Function recursive_infer

core/recursive.py:244–431

Self-refining inference: draft → critique → refine loop. Wraps core/inference_v2.infer() without changing the agent's message history or tool-call protocol. The refined response is returned in place of the plain infer() response. Args: messages: Full message l

(
    messages: list,
    task_type: str = "code",
    user_message: str = "",
    max_depth: int = None,
    quality_threshold: float = None,
    extra_stop: list = None,
    stream: bool = True,
)

# ── Main API ──────────────────────────────────────────────────────────────────

def recursive_infer(
    messages: list,
    task_type: str = "code",
    user_message: str = "",
    max_depth: int = None,
    quality_threshold: float = None,
    extra_stop: list = None,
    stream: bool = True,
) -> str:
    """
    Self-refining inference: draft → critique → refine loop.

    Wraps core/inference_v2.infer() without changing the agent's message history
    or tool-call protocol. The refined response is returned in place of the
    plain infer() response.

    Args:
        messages:          Full message list (system + history + user message)
        task_type:         "code" | "write_file" | "patch_file" | "plan" | "tool"
        user_message:      Original user message text (for KB retrieval queries)
        max_depth:         Max critique+refine cycles (default from RECURSIVE_CONFIG)
        quality_threshold: 0–1 gate; above this the draft is accepted (default 0.7)
        extra_stop:        Additional stop tokens forwarded to infer()
        stream:            Whether to stream final output tokens (default True)

    Returns:
        Final (possibly refined) response string. Never raises — errors are returned
        as "[ERROR] ..." strings matching the normal infer() contract.
    """
    # Guard: return immediately if recursive inference is disabled
    if not RECURSIVE_CONFIG.get("enabled", True):
        from core.inference_v2 import infer
        return infer(messages, stream=stream,
                     extra_stop=extra_stop or ["</tool>"], show_thinking=True)

    cfg = RECURSIVE_CONFIG
    if max_depth is None:
        max_depth = cfg.get("max_depth", 1)
    if quality_threshold is None:
        quality_threshold = cfg.get("quality_threshold", 0.7)
    if extra_stop is None:
        extra_stop = ["</tool>"]

    # Phase 8: Adapt depth to thermal/battery state
    max_depth = get_adaptive_depth(max_depth)

    # ── Step 1: Generate initial draft ────────────────────────────────────────
    try:
        from core.inference_v2 import infer
    except Exception as e:
        return f"[ERROR] recursive_infer: cannot import infer: {e}"

    try:
        _log_phase("Draft", 1, max_depth + 1)
        draft = infer(messages, stream=stream,
                      extra_stop=extra_stop, show_thinking=True)
    except Exception as e:
        return f"[ERROR] recursive_infer draft: {e}"