Function _call_model_sync

src/query/query.py:495–1015

(
    *,
    provider: BaseProvider,
    messages: list[Message],
    system_prompt: str,
    tools: Tools,
    max_output_tokens_override: int | None = None,
    abort_signal: Any = None,
    on_text_chunk: Callable[[str], None] | None = None,
    on_thinking_chunk: Callable[[str], None] | None = None,
    extended_thinking: bool | None = None,
    thinking_effort: str = "medium",
    sdk_max_retries: int | None = None,
)

async def _call_model_sync(
    *,
    provider: BaseProvider,
    messages: list[Message],
    system_prompt: str,
    tools: Tools,
    max_output_tokens_override: int | None = None,
    abort_signal: Any = None,
    on_text_chunk: Callable[[str], None] | None = None,
    on_thinking_chunk: Callable[[str], None] | None = None,
    extended_thinking: bool | None = None,
    thinking_effort: str = "medium",
    sdk_max_retries: int | None = None,
) -> tuple[list[AssistantMessage], list[ToolUseBlock]]:
    from ..types.messages import normalize_messages_for_api
    from ..utils.advisor import (
        ADVISOR_BETA_HEADER,
        ADVISOR_MODE_CLIENT_SIDE,
        ADVISOR_MODE_INACTIVE,
        ADVISOR_MODE_SERVER_SIDE,
        ADVISOR_TOOL_INSTRUCTIONS,
        build_advisor_tool_schema,
        build_client_advisor_tool_schema,
        decide_advisor_mode,
        strip_advisor_blocks,
    )

    # Advisor activation decision. Three outcomes:
    #
    # * SERVER_SIDE: 1P Anthropic provider + opus-4-6/sonnet-4-6 main
    #   loop + valid server-side advisor target. Carries the beta
    #   header and the ``advisor_20260301`` schema; the API runs the
    #   reviewer model server-side. Optimal path — single roundtrip,
    #   cache-friendly.
    # * CLIENT_SIDE: any provider, any tool-calling main loop, any
    #   advisor model that routes to a known provider. Registers
    #   ``advisor`` as a regular client-side tool; the dispatcher
    #   (``src/tool_system/tools/advisor.py``) makes a separate API
    #   call to the configured advisor model. Two roundtrips but
    #   provider-agnostic.
    # * INACTIVE: no advisor on this request (env-disabled, no
    #   advisor_model set, or no path can be resolved).
    #
    # The full decision table lives in ``decide_advisor_mode``. Any
    # exception during the predicate degrades to INACTIVE rather than
    # killing the turn (critic M1 from the original advisor PR).
    main_loop_model = getattr(provider, "model", "") or ""
    advisor_mode = ADVISOR_MODE_INACTIVE
    advisor_model_normalized: str | None = None
    try:
        from ..settings.settings import get_settings
        settings = get_settings()
        configured = (getattr(settings, "advisor_model", "") or "").strip()
        configured_provider = (getattr(settings, "advisor_provider", "") or "").strip()
        force_client = bool(getattr(settings, "advisor_client_mode", False))
        # Master switch (default False): the advisor stays inactive unless the
        # user opted in via `advisor_enabled` in ~/.clawcodex/config.json.
        advisor_enabled = bool(getattr(settings, "advisor_enabled", False))