+ iHjaRtx0tRt^RIHt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t HtHtHt^RIHt^RIHtHtHt^RIHtHtHtHtHtHtHtHtH t H!t!^RI"H#t#H$t$H%t%^R I&H't'^R I(H)t)R s*]^kRs+]^kR t,RR Rllt-]P\!]/4t0RRRRRRRR/t1RRRRRRRRRRRRRR/t2Rt3Rt4Rt5Rt6R R!lt7R"R#lt8/RR$bR%R$bR&R$bR'R$bRR$bRR(bRR(bRR(bRR(bR)RbR*R(bR+R$bR,R-bR.R-bR/R0bR1R0bR2R0bR3R4R5R6/Ct9R$t:R7R8lt;R9R:ltlt>R?R@lt?RARBlt@RCRDltARERFltBRGRHltCRItDRJ]D.tERKtFRLtGRMRN.tHROtIRsJ]^kRtKRtLRPRQltMRRRSltNRTRUltORVRWltPRXtQRYtRRZR[R\R]/tS]SP4UUu/uFwrWbK upptU]V!RZ04tW]X;QJd.R^]Y!]W44FNK 5M!R^]Y!]W444tZR_R`lt[RaRb/RcRdllt\ReRflt]RgRhlt^Rit_RjRklt`RRaRb/RlRmllltaRRnRolltbRpRqltcRrRsltdRRaRb/RtRulllteRvRwltfRxRyltgRzR{lthRti]P!R|4tkR}tlR~RltmRRR/RRR/RRR//tnRRRllto]V!0Rm4tpRR/RRlltqRRltr!RR4tsRRlttRRltuRtvRRRRRRRR/RRlltwR#uuppi)aAnthropic Messages API adapter: client construction + the Messages call for Hermes's OpenAI-style internals. Auth: Console API keys (``sk-ant-api*``/``-usr*``/``-svc*``/``-admin*``) -> x-api-key; OAuth setup-tokens (``sk-ant-oat*``) and Claude Code credentials -> Bearer + beta header. Endpoint predicates, payload conversion and credentials live in ``agent/anthropic_{endpoints, message_convert,credentials}.py``; import them from there.) install_hintN)suppress)AnyDictListOptional)normalize_proxy_env_vars)_is_oauth_tokenanthropic_route_is_oauthis_native_anthropic_host) _base_url_needs_context_1m_beta_is_azure_anthropic_endpoint_is_kimi_coding_endpoint_is_minimax_anthropic_endpoint_is_nous_portal_endpoint_is_opencode_endpoint"_is_third_party_anthropic_endpoint_model_name_is_kimi_family_normalize_base_url_text_requires_bearer_auth)convert_messages_to_anthropicconvert_tools_to_anthropicnormalize_model_name)EmptyStreamError)get_version_info.c\RJd^RIHpV!R4^RIpVs\#\# \d pTsRp?L%Rp?ii;i \ d Rs\#i;i)zMReturn the ``anthropic`` SDK module, importing lazily. None if not installed..) ensure_import anthropicN)_anthropic_sdkpmr Exception_anthropic_install_errorr ImportError)rexc_sdks  +'* $ +  "!N  "s#-A A?A AAc0V^8dQhR\R\/#)purposeverbstr)formats"r% __annotate__r.;s  # S c \4pVf#\e\RV R\ 24\hVf\RV RV R\R4 24hV#)zI``_get_anthropic_sdk()`` or ImportError naming the feature that needs it.z(The 'anthropic' package is required for z: z. r)r&r!r"r)r)r*sdks&& r% _require_sdkr2;sr  C {/;DWIR5689>V W {DWIRPTvUW)+679: : Jr/xhighi}highi>medium@lowiultramaxminimalclaude-opus-4-5claude-sonnet-4-5claude-haiku-4-5claude-opus-4-6claude-sonnet-4-6 claude-fablec>V^8dQhR\R,R\/#)r(modelNreturnr,bool)r-s"r%r.r.ms--C$J-4-r/c<RT;'gRP49#)claude)lowerrBs&r%_is_claude_modelrKms  **, ,,r/c0V^8dQhR\R\/#r(rBrCrD)r-s"r%r.r.qs++#+d+r/caVP4o\;QJdV3RlV4F 'gK R# R#!V3RlV44#)zDCase-insensitive substring match of ``model`` against a family list.c3,<"TF qS9xK R#5iN).0vms& r% !_model_matches..ts*z!AvzsTF)rIany)rB substringsrTs&&@r%_model_matchesrYqs7 A 3*z*33*3*3*z* **r/izclaude-sonnet-5zclaude-opus-4-8zclaude-opus-4-7iz claude-opus-4zclaude-sonnet-4zclaude-3-7-sonnetzclaude-3-5-sonneti zclaude-3-5-haikuz claude-3-opuszclaude-3-sonnetzclaude-3-haikuminimaxiqwen3ic0V^8dQhR\R\/#rM)r,int)r-s"r%r.r.s__S_S_r/caVP4PRR4o\V3Rl\4\RR7pV'd\V,#\ #)zMax output tokens for ``model`` via longest substring match against ``_ANTHROPIC_OUTPUT_LIMITS`` (so date-stamped ids and ``:1m``/``:fast`` suffixes resolve, and ``claude-3-5-sonnet`` beats ``claude-3-5``). Dots normalize to hyphens (``claude-opus-4.6``)..-c38<"TFqS9gK VxK R#5irPrQ)rRkeyrTs& r%rU,_get_anthropic_max_output..sH#;CaxCC#;s N)rcdefault)rIreplacer9_ANTHROPIC_OUTPUT_LIMITSlen_ANTHROPIC_DEFAULT_OUTPUT_LIMIT)rBbest_keyrTs& @r%_get_anthropic_max_outputrksG  c3'AH#;Hc[_`H19 #H -^?^^r/c:V^8dQhR\\,/#r(rC)rr^)r-s"r%r.r.s 2 2Xc] 2r/c\V\4'g\V\\34'gR#\P !V4'gR#\T4^8d \T4#R# \ dR#i;i)a``value`` floored to a positive int, or None when it is not a finite positive number. Anthropic 400s on max_tokens that are 0, negative, fractional or non-finite; the ``max_tokens or fallback`` idiom catches 0 but lets ``-1``/``0.5`` through. Booleans are excluded (they subclass int).N) isinstancerEr^floatmathisfiniter )values&r%&_resolve_positive_anthropic_max_tokensrtso %je &E&E}}U##$Ua3u:1T1 sA22 BBcRV^8dQhR\R\\,R\/#)r(rBcontext_lengthrC)r,rr^)r-s"r%r.r.s)  S RZ[^R_ kn r/cx\V4;'g \V4pV^8dV#\RV: RV: R24h)z``requested`` when it is a positive finite number, else the model's output ceiling. Raises ValueError if neither is positive. The context-window clamp is the caller's job so the positive-value contract stays endpoint-agnostic.zJAnthropic Messages adapter requires a positive max_tokens value for model z; got z and no model default resolved.)rtrk ValueError) requestedrBrvresolveds&&& r%&_resolve_anthropic_messages_max_tokensr{sO6i@ddD]^cDdH!|    },K M r/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.sstr/cx\V4;'g)\V4;'d\V\4'*#)u True for Claude models using adaptive thinking (4.6+): unknown Claude models default to adaptive, the explicit legacy list stays manual, and non-Claude models return False — except Kimi/Moonshot, whose Anthropic-compatible endpoints implement the adaptive contract.)rrKrY)_LEGACY_MANUAL_THINKING_CLAUDE_SUBSTRINGSrJs&r%_supports_adaptive_thinkingrs6 &e ,  hhu>g(h$hr/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.sii#i$ir/cR\V4;'d\V\4'*#)uTrue for models accepting the 'xhigh' effort (Opus 4.7+). Opus/Sonnet 4.6 400 on it — callers downgrade xhigh->max when this returns False.)rrY_NO_XHIGH_CLAUDE_SUBSTRINGSrJs&r%_supports_xhigh_effortrs" 'u - h hnULg6h2hhr/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.s  S T r/c\V4;'d4\V4;'d!\V\\,4'*#)aTrue when ``model`` accepts an explicit ``thinking: {"type": "disabled"}``. Adaptive Claude thinks by default, so "off" only works if the disable is sent; mandatory-thinking families 400 on it and keep the omit behavior. Legacy manual-thinking models are opt-in via budget_tokens, so omission is already off. Scoped to Claude: Kimi's documented disable is omission, and sending it a new parameter on the strength of Claude's contract is a guess.)rKrrY%_MANDATORY_THINKING_CLAUDE_SUBSTRINGS$_BETWEEN_TOOLS_OFF_CLAUDE_SUBSTRINGSrJs&r%_accepts_thinking_disablersE  t t ' . t tu&KNr&rs sr/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.sHH#H$Hr/c^RIHpRVP49dR#V!V4pVRJ;'g!V^,R8g;'g V^,R8#)zeHaiku generations that never get a thinking request (through 4.5). Haiku 5.5+ uses adaptive thinking.)claude_family_versionhaikuFN)r)agent.anthropic_thinking_policyrrI)rBrparseds& r%_is_pre_thinking_haikursLEekkm# "5 )F T> G GVAY'1 G GVAY5GGr/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.sCDr/ch\V4;'d!\V\\,4'*#)uTrue for models that 400 on any non-default temperature/top_p/top_k (Opus 4.7 and later; unknown Claude defaults to forbidding). The 4.6 family and the legacy manual-thinking families still accept them. Callers omit the fields entirely — the API rejects anything non-null.)rKrYrr~rJs&r%_forbids_sampling_paramsrs3 E "  > *-VV,(r/c0V^8dQhR\R\/#rMrD)r-s"r%r.r.s//s/t/r/c^RIHpV!V4#)zTrue for models accepting ``speed: "fast"`` (Opus 4.8 / Opus 5 / Opus 5.5, Claude API only). The list lives in ``agent.model_metadata`` so the wire gate and the ``/fast`` toggle agree.)is_anthropic_fast_mode_model)agent.model_metadatar)rBrs& r%_supports_fast_modersB ' ..r/z&fine-grained-tool-streaming-2025-05-14zinterleaved-thinking-2025-05-14zcontext-1m-2025-08-07zfast-mode-2026-02-01zclaude-code-20250219zoauth-2025-04-20z2.1.74c:V^8dQhR\\,/#rm)listr,)r-s"r%r.r.scr/c/p\F4p\P!V4pV'gK#VPV4K6 \Fp\Fxp\ P P\ P PV4V4p\ P PV4'gKgVPV4Kz K \V4#)aExecutable paths to try, deduped and filtered to files that exist. Two passes: every PATH hit first (what the user's shell would run), then the well-known install prefixes. A single nested loop would probe a stale prefix ``claude`` before a current PATH ``claude-code``. ) _CLAUDE_CODE_NAMESshutilwhich setdefault_CLAUDE_CODE_PREFIXESospathjoin expanduserisfiler)seennamehitprefixrs r%_claude_code_candidatesrsD"ll4  3 OOC #(&D77<< 2 26 :DADww~~d##%'( :r/cFV^8dQhR\R\\,/#)r(commandrC)r,r)r-s"r%r.r.s ' '# '(3- 'r/c~V\9dR#^RIHpV!V\R7PpV'd V^,#R#)a#Path of a bare Claude Code command name on PATH, else in an install prefix; None for any other command. Core's own presence checks (external-process providers, ``claude setup-token``) ask this so they agree with version detection about whether the CLI is installed under a GUI/service PATH.N)locate_command) known_dirs)rhermes_platform.resolverrrr)rrfounds& r%find_claude_code_clirs7 ((7 7/D E M ME58&$&r/c$V^8dQhR\/#rmr+)r-s"r%r.r.&s ) )S )r/c\4Fp\\4;_uu_4\P!VR.\P RRRR^RR7pVP ^8XdVPP4'dcVPP4P4^,pV'd,V^,P4'dVuuRRR4u#RRR4K \# +'giK;i)zOInstalled Claude Code version (``claude --version``), else the static fallback.z --versionTzutf-8rfF)stdincapture_outputtextencodingerrorstimeoutcheckN) rrr subprocessrunDEVNULL returncodestdoutstripsplitisdigit_CLAUDE_CODE_VERSION_FALLBACK)cmdresultversions r%_detect_claude_code_versionr&s&( i ^^k" ((DSZclvwF   A%&--*=*=*?*? ----/557:wqz1133"! ) )(! sAC96C9<C9C99 D c$V^8dQhR\/#rmr+)r-s"r%r.r.6s&&#&r/c2\f \4s\#)zEDetect lazily (only OAuth headers need it) and cache for the process.)_claude_code_version_cacherrQr/r%_get_claude_code_versionr6s")%@%B" %%r/z9You are Claude Code, Anthropic's official CLI for Claude.mcp__session_searchchat_history_lookupmemory context_notesc#"TF@p\P!R\P!V4 R24\V,3xKB R#5i)z\bN)recompileescape_OAUTH_TOOL_NAME_ALIASES)rRrs& r%rUrUQs=$0ZZ2biio&b)*,DT,JK0sAA c0V^8dQhR\R\/#)r(rrCr+)r-s"r%r.r.WsSSr/cF\FwrVPW 4pK V#)z@Rewrite prose-safe tool-name tokens to their OAuth wire aliases.)_OAUTH_PROSE_ALIAS_PATTERNSsub)rpattern wire_names& r%_apply_oauth_prose_aliasesrWs"9{{9+: Kr/drop_context_1m_betaFc`V^8dQhR\R,R\R\\,/#)r(base_urlNrrC)r,rEr)r-s"r%r.r.^s,  t d _cdg_h r/c\\4p\V4'dV'gVP\4\ V4'd%VUu.uFq3\ \39gKVNK up#V#uupi)uBeta headers safe for the configured endpoint. MiniMax (Bearer-auth) rejects both the fine-grained-tool-streaming beta (every tool-use message errors) and the 1M-context beta. Azure AI Foundry also uses Bearer auth but keeps both — it needs the 1M beta for 1M context, which native Anthropic does not get by default (some subscriptions reject it; Bedrock opts in via its own client helper). ``drop_context_1m_beta`` strips the 1M beta after a subscription/endpoint rejected it.)r _COMMON_BETASr append_CONTEXT_1M_BETAr_TOOL_STREAMING_BETA)rrbetasbs&$ r%_common_betas_for_base_urlr^sb  E&x009M %&%h// V5a.BDT-U$U5VV LWs A5*A5cRV^8dQhR\R\\\3,/#)r(rrC)rdictr,)r-s"r%r.r.ms&@@@c3h@r/c<V'dRRPV4/#/#)z>``{"anthropic-beta": ...}`` when there are betas, else ``{}``.zanthropic-beta,)r)rs&r% _beta_headerrms27 chhuo .?R?r/cFV^8dQhR\\\3,/#rmrr,)r-s"r%r.r.rsd38nr/c<RRRRRR\4P 2/#)zOSame client-attribution set sent to OpenRouter / Vercel AI Gateway / Fireworks.z HTTP-Refererz%https://hermes-agent.nousresearch.comzX-Title Hermes Agentz User-Agentz HermesAgent/)r base_versionrQr/r%_attribution_headersrrs/ ?N %5%7%D%D$EF r/c^RIHp\V\\34'd V^8dTMRpV!\ V4RR7#)zNhttpx.Timeout with the caller's read timeout (default 900s) and a 10s connect.)Timeoutg @g$@)rconnect)httpxrror^rp)rrreads& r%_client_timeoutrzs3!'C<88Wq[7uD 5; 55r/chV^8dQhR\\\\\3,3,/#rm)tupler,rr)r-s"r%r.r.s%  eCc3h4G.H r/cR\V4R^/p\P!RR\V4P R44pV'd$W2R&\ V4'dRV9dRR/VR &W23#) aShared SDK constructor kwargs -> ``(normalized_base_url, kwargs)``. Retry is delegated to hermes's outer loop (``max_retries=0``): the SDK default of 2 uses its own backoff that ignores Retry-After and double-retries inside our loop. Any trailing ``/v1`` is stripped because the SDK appends ``/v1/messages``. Azure's ``api-version`` goes through ``default_query`` so the base_url is not corrupted into ``/anthropic?api-version=.../v1/messages``.r max_retriesz/v1/?$rH/rz api-versionz 2025-04-15 default_query)rrrrrstripr )rrkwargs normalizeds&& r%_base_client_kwargsrsq ()A=RSTF 2'?'I'P'PQT'UVJ'z ' 3 3 Z8W'4l&CF? #  r/cXV^8dQhR\R,R\R,R\/#r(rNrrr,rprE)r-s"r%r.r.s1AA!DjA:?$,AhlAr/ct\RRR7p\4^RIHp\ W4wrgT!YR,\ V4'dRMRR7VR &R VR &\ WcR 7p\W4'd.\V\,4p R \4 R2V R&RV R&M \V4p \WGWR7#)aAnthropic-on-Foundry Entra ID variant of :func:`build_anthropic_client`. The SDK stores ``api_key``/``auth_token`` as static strings, so per-request bearer refresh (Microsoft's documented Foundry pattern) uses a custom ``httpx.Client`` whose request hook mints a fresh JWT and rewrites ``Authorization``; the SDK skips its own auth when ``http_client`` is given. The placeholder ``auth_token`` is still required at construction and makes any leak diagnosable.z:Azure Foundry Anthropic-style endpoints with Entra ID authz Install with)r*)build_bearer_http_clientrc"\V4'*#rP)r )tokens&r%:_build_anthropic_client_with_bearer_hook..s OE,B(Br/N)rsends_as_api_key http_clientzentra-id-bearer-via-http-hook auth_tokenr claude-code/ (external, cli) user-agentclix-approute) r2ragent.azure_identity_adapterrrr rr r_OAUTH_ONLY_BETASr_new_sdk_client) token_providerrrrr1rnormalized_base_urlrrheaderss &&&$ r%(_build_anthropic_client_with_bearer_hookrs SZh iCE"5h"H 5y 1G_`hGiGiBosF=;F< &': fE99u'889"./G/I.JJZ [  u% 3 @@r/cV^8dQhR\\\3,R\\\3,R\R,/#)r(rrrNrr,r)r-s"r%r.r.s8##c3h#$sCx.#QTW[Q[#r/c@\V4pRV9dRV9dVP4VR&M!RV9dRV9dVP4VR&TP\T;'gVP R444V'dWAR&VP !R/VB#)uD``sdk.Anthropic(**kwargs)`` with ``headers`` attached, sending exactly ONE credential. ``route`` is the caller's un-normalized base_url (the ``/v1`` form ``custom_providers`` entries are keyed by; ``kwargs["base_url"]`` has it stripped) for the per-provider ``extra_headers`` lookup. The SDK fills whichever of ``api_key`` / ``auth_token`` we left unset from ANTHROPIC_API_KEY / ANTHROPIC_AUTH_TOKEN in the environment (both loaded from ~/.hermes/.env) and then sends dual auth — x-api-key *and* Authorization: Bearer — shipping a foreign credential to Portal / MiniMax / OAuth / Entra / third-party endpoints (#26970, #105774). An ``Omit()`` default header is the SDK-sanctioned way to drop the other header, and unlike an attribute clear it survives ``with_options()``, which re-runs the constructor and re-reads the environment.api_keyr Authorizationz X-Api-Keyrdefault_headersrQ)rOmitupdate_custom_provider_extra_headersget Anthropic)r1rrrmergeds&&&& r%rrs']FF|69"%((*  IV$;!hhj{ MM01P1P&**Z:PQR $* ! == "6 ""r/cFV^8dQhR\\\3,/#rmr)r-s"r%r.r.s  S#X r/cV'g/#^RIHpV!\V44# \d\P RRR7/u#i;i)u``extra_headers`` of the ``custom_providers`` entry routed at *base_url*, else ``{}``. SECURITY: values routinely carry credentials (Cloudflare Access tokens) — never log them.)!get_custom_provider_extra_headersz:custom-provider extra_headers skipped for Anthropic clientTexc_info)hermes_cli.configr-r,r loggerdebug)rr-s& r%r'r'sI  G0X??  Q\` a s#$A  A c$V^8dQhR\/#rmr+)r-s"r%r.r.s3r/c\V4'dR#\V4'dR#\V4'dR#\V4'dR#R#)u1Order-sensitive endpoint/key classification for :func:`build_anthropic_client`. ``kimi``: Kimi's /coding endpoint 403s without a User-Agent (the Kimi team asked for proper attribution). ``bearer``: MiniMax & co. want Authorization: Bearer — checked before the OAuth shape test because their secrets lack the sk-ant-api prefix and would be misread as OAuth/setup tokens. ``api_key``: third-party proxies use their own x-api-key keys (skip OAuth detection). ``oauth``: Bearer auth + Claude Code identity (Anthropic routes OAuth by user-agent; without it, 500s).kimibearerr"oauth)rrrr )r"rrs&&&r% _auth_styler8s@ ))011)(33w r/cXV^8dQhR\R,R\R,R\/#rr)r-s"r%r.r.s0AAcDjA%RV,Ax|Ar/cr\R4p\V4'd$\V\4'g\ WW#R7#\ 4\ W4wrVRV9dVPR4VR&\WSR7p\WV4pYVR9dRMR&\VR8XdV\,MT4p VR 8Xd/\4CV Cp MVR8XdR \4 R 2V R &R V R&\V4'd3\4P4FwrV P!W4K \#WFWR7#)uCreate an Anthropic client, auto-detecting setup-tokens vs API keys. ``api_key`` is a static ``str`` or a ``Callable[[], str]`` Entra ID bearer provider (routed through :func:`_build_anthropic_client_with_bearer_hook`). ``timeout`` overrides the 900s read timeout (connect stays 10s). ``drop_context_1m_beta`` strips ``context-1m-2025-08-07`` from the client-level beta header — the reactive OAuth retry in run_agent uses it after a subscription rejects it; fresh clients keep the default so 1M-capable subscriptions keep the capability.zthe Anthropic providerrrrrr7rr"r5rrrrrr)r6r7)r2callableror,rrrrrr8rrrrritemsrr) r"rrrr1rr common_betasstylerkrSs &&&$ r%build_anthropic_clientr@s4 / 0CGS!9!97 w  "5h"H& 077<z-.AmL +> ?EJQ5$77``. Anthropic's OAuth billing classifier treats a single-underscore ``mcp_`` tool name as a third-party-app fingerprint (HTTP 400 "Third-party apps now draw from extra usage"); ``mcp__foo`` is accepted. Both bare Hermes tools (``read_file``) and native MCP tools registered as ``mcp__`` must land on the double-underscore form. normalize_response reverses both via registry lookup.rmcp_) startswith_MCP_TOOL_PREFIX removeprefix)rs&r%_normalize_to_mcp_wirer["s.  w d//7 77r/c\V^8dQhR\\\\3,,/#)r(anthropic_tools)rrr,r)r-s"r%r.r.-s tDcN';r/caT;'g.Uu0uFPp\VPR4\4'gK*VR,\9gK>\ VR,4kKR upoRV3RllpV#uupi)aWReturn ``name -> OAuth wire name`` for this request's tool set. An alias must never collide with a wire name owned by a non-alias tool: two identical tool names in one request is a hard 400, strictly worse than the bug being fixed. Mirrors normalize_response's "registered tool wins" so outbound and inbound agree on who owns a contested name.rc0V^8dQhR\R\/#rUr+)r-s"r%r.'_oauth_wire_namer..__annotate__8s,,c,c,r/c|<\PV4pV'd\V,S9dTp\V4#rP)rr(rYr[)raliasedclaimeds& r%to_wire"_oauth_wire_namer..to_wire8s3*..t4 ''1@D%d++r/)ror(r,rr[)r]toolrdrcs& @r%_oauth_wire_namerrg-st%****D dhhv& , -15fE]1] -tF|,*G ,, Ns'A4A4A4z-(?"4<0DL dhh}-s 3 3"tCH~cY\aefiknfnaor/c  VPR4RJd6\V\4'dRRR//#\V4'dRRR//#/#\ V4'd/#\ VPRR44P 4p\V4'd=\PVR4pVR 8Xd\V4'gR pRRR R R /RRV//#\PVR4pRRRRV/R^R\W%R,4/#)aMap ``reasoning_config`` to Anthropic thinking kwargs. Adaptive models (Claude 4.6+, Kimi/Moonshot) get ``thinking.type=adaptive`` + ``output_config.effort``; older models and manual-only compat endpoints (MiniMax) get budget_tokens. Haiku through 4.5 gets none. On 4.7+ ``thinking.display`` defaults to "omitted", hiding the reasoning Hermes shows in its CLI, so "summarized" is requested to keep the activity feed populated.enabledFthinkingri between_toolsdisabledeffortr5r3r9adaptivedisplay summarized output_configr6 budget_tokens temperature max_tokensrZ) r(rYrrrr,rIrADAPTIVE_EFFORT_MAPrTHINKING_BUDGETr9)rzrBr{radaptive_effortbudgets&&& r%_thinking_kwargsrhs I&%/ %!E F F 9: :5Nu5U5U VZ01][]]e$$ !%%h9 : @ @ BF"5))-11&(C g %.DU.K.K#OVZLI?]egv\wxx   .FVY@qc. > r/riautorequiredrWcV^8dQhR\R\\,R\\\,,R\\,R\\\\ 3,,R\\,R\ R\ R \\,R \R ,R \ R \ R\\\ 3,/ #)r(rBmessagestoolsrrz tool_choiceis_oauth preserve_dotsrvrN fast_moderrC)r,rrrr^rrE)r-s"r%r.r.sAA At*A-5d4j-AAOWX[}AtCH~.A=Ec]AA,0AJRRUADj A-1 AQU A  #s(^ Ar/c \WVR7wrV'd \V4M.p\V 4'g \WR7p\ W0VR7pV'dW8d\ V^, ^4pV'd \ V4MRpV'd\WV V4p RVRV RV/pV 'dV VR&V'dpVVR &VR 8XdVPR R4MPVe\V\4'd7\PV4;'gR R R V'd V!V4MT/VR&V'd2\V\4'dVP\W@V44\!V4'dRFpVPVR4K V 'ds\#V 4'gb\%V4'dQRVP'R/4R&\)WR7p\+TV'd\,M.,\..,4VR&V#)uBuild kwargs for anthropic.messages.create(). ``max_tokens`` is the OUTPUT cap for one response; ``context_length`` is the TOTAL window (input + output). ``max_tokens=None`` uses the model's native output ceiling; if that exceeds ``context_length`` (small local endpoints) it is clamped to ``context_length - 1``. The clamp ignores prompt size — callers must catch "max_tokens too large given prompt" and retry smaller (parse_available_output_tokens_from_error). ``is_oauth`` applies Claude Code compatibility transforms; ``preserve_dots`` keeps model-name dots (DashScope: qwen3.5-plus); a third-party ``base_url`` strips thinking signatures; ``fast_mode`` adds ``extra_body.speed="fast"`` plus the fast-mode beta on native Anthropic only.)rrB)r)rvNrBrrrqrnonerirfrrfast extra_bodyspeedr extra_headers)rtop_ptop_k)rrrrr{r9rgrxpopror,_TOOL_CHOICE_MAPr(rr&rrrrrrrr_FAST_MODE_BETA)rBrrrrzrrrrvrrrrqrrr]r{rdrrcrs&&&&&&&&&&&& r%build_anthropic_kwargsrs"?xbg!hF;@07bO $H - -$UHA*drs.?">A#5q94<0$G,VFXZab%uj:Ll\pqF !x)w & JJw %  J{C$@$@%5$8$8$E%% (<[JF= !J'7>> &'7@TUV &&4C JJsD !5 ;HEEJ]^cJdJd7=,+G4*8_".uX8I[]/^bqar/r"s Mr/ log_prefixrHc<V^8dQhR\R\R\/#)r( api_kwargsrrC)rr,)r-s"r%r.r.s!#c3r/c\V\4'd\PV4MRpV'd,VFpWK \P RV\ V44V#)aDrop Responses-API-only keys before an Anthropic Messages SDK call. Boundary guard for api_mode-flip races (a concurrent auxiliary call mutating a shared agent between kwargs build and dispatch): a Responses-shaped payload reaching ``messages.stream()`` dies with a non-retryable TypeError that takes the whole turn and fallback chain with it. Mutates and returns ``api_kwargs``; logs a WARNING so the race stays visible.u%sStripped Responses-only kwarg(s) %s from an Anthropic Messages call (api_mode flip race — see #31673). The call will proceed; this breadcrumb means a kwargs build ran under a Responses api_mode while dispatch ran under anthropic_messages.rQ)ror_RESPONSES_ONLY_KWARGS intersectionr1warningsorted)rrleakedrcs&$ r%sanitize_anthropic_kwargsrs_ AK:W[@\@\ # 0 0 #=h#GGw'--2-(- $%.r/c6a]tRtRtoRtRtRtRtRtVt R#)_UsageNormalizingStreamizYRaw SSE iterator proxy that fills ``usage: null`` before the SDK accumulates it (#60683).cWnR#rP_inner)selfinners&&r%__init__ _UsageNormalizingStream.__init__s r/c.\VPV4#rP)getattrr)rrs&&r% __getattr__#_UsageNormalizingStream.__getattr__st{{D))r/c#\"^RIHpHp^pVPFp\ VRR4pVR8XdO\ VRR4p\ VRR4pVeVfV!^^R7VnM@Ve\ VR^4;'g^pM$VR 8Xd\ VRR4fV!VR 7VnVxK R#5i) )MessageDeltaUsageUsageriN message_startmessageusage) input_tokens output_tokensr message_delta)r)anthropic.typesrrrrr)rrrreventetyperrs& r%__iter__ _UsageNormalizingStream.__iter__s< [[EE640E'!%D9$7&5=$)q$JGM&$+E?A$F$K$K!M/)geWd.K.S0mL K!s A7B,:2B,rN) __name__ __module__ __qualname____firstlineno____doc__rrr__static_attributes____classdictcell__) __classdict__s@r%rrsc*r/rc0V^8dQhR\R\/#)r(message_streamrC)r)r-s"r%r.r.s  3 3 r/cp\VRR4pVe\VR4'gV#\V4VnV#)aOPatch ``usage: null`` on raw SSE events before the SDK accumulates them. Anthropic-compatible providers (MiniMax) send ``usage: null`` on message_start and/or message_delta; the SDK's accumulate_event() then dies on ``usage.output_tokens`` mid- iteration (#60683). Wraps ``MessageStream._raw_stream`` in place; no-op for other shapes. _raw_streamNr)rrPrr)rraws& r%normalize_stream_usagers< .- 6C {'#z22!8!=N r/c0V^8dQhR\R\/#)r(r#rC)r rE)r-s"r%r.r. s 1 1i 1D 1r/c\V4P4pRV9d RV9dR#RV9dR#RV9dR#^RIHpV!V4#)z@True when an Anthropic stream call should fall back to create().streamz not supportedTzunexpected event orderinvokemodelwithresponsestreamF) is_streaming_access_denied_error)r,rIrOr)r# err_lowerrs& r%_is_stream_unavailable_errorr sHC I9I!=9,&i7F +C 00r/c T!R/VP4UUu/uFwrVVR8wgKWVbK uppB;_uu_4p\V4p\V4'dV!\VRR44RpRp VFcp \V RR4R 8XdRp \V RR4R 8Xd\\V R R4R R4p V eT p\V4'gKZV!V 4Ke V 'g \R4hVP4p VeWn V uuRRR4#uuppi \d\ P RTRR7Li;i \dh\d\ P R TRR7EKi;i +'giR#;i)zJ``messages.stream()`` -> final Message, ticking the best-effort callbacks.rresponseNz%son_response callback failedTr.Fri message_stoprdelta stop_detailsz!%son_stream_event callback failedzTAnthropic Messages stream ended before message_stop (possible upstream stream drop).rQ) r<rr;rr r1r2 TimeoutErrorrget_final_messager) stream_fnrron_stream_event on_responser?rSrrsaw_message_stoprdetailsrs &&&&& r%_stream_final_messager-s  Lz'7'7'9K'9tqQ(]dad'9K L LPV'/ K  YGFJ=>  Eufd+~=#' ufd+>!'%$"?QUV&#*LO,, ]&$ "f **,  ##/ Q M LK  Y D??E8E5 E5 0E84E5 5E88 F prefer_streamTrrc TV^8dQhR\R\R\R\R\/#)r(clientrrrrC)rrr,rE)r-s"r%r.r.Zs=YY Y!Y25YKOY Yr/c \WR7\VRR4p\VRR4pV'd \V4'd\WqW$V4#VP!R/VP4U U u/uFwrV R8wgKWbK up p B# \dh\ d3p\ T4'gh\PRY(4Rp?LRp?ii;iuup p i)aCreate an Anthropic message, aggregating via stream when available. Some Anthropic-compatible gateways are SSE-only and answer ``create()`` with ``text/event-stream``, which the SDK surfaces as raw text (callers then crash on ``.content``), so prefer ``messages.stream()`` like the main turn path and fall back to ``create()`` only for providers that explicitly don't support streaming (restricted Bedrock roles). Both callbacks are best-effort and fire only on the streaming path: ``on_stream_event(event)`` lets liveness watchdogs see forward progress; ``on_response(httpx_response)`` exposes headers the parsed Message drops (Nous Portal's ``x-nous-credits-*`` balance family).)rrNrzN%sAnthropic Messages stream unavailable; falling back to messages.create(): %srQ) rrr;rrr rr1r2creater<) rrrrrr messages_apirr#r?rSs &&$$$$ r%create_anthropic_messagerZsj@6:t4L h5I),, ( ]hi i    X:3C3C3E!W3E41h$!$3E!W XX   /44 LL`bl    "Xs* B / C?C C C!(CCcV^8dQh/^\9d \;R&^\9d\\,;R&^\9d\\,;R&#)r(rr!r)__conditional_annotations__rrr r,)r-s"r%r.r.sQ>>FG>L54(9-4M>f10HSM0g>r/)zInstall it with)zclaude-3zclaude-opus-4-0zclaude-opus-4.0zclaude-opus-4-1zclaude-opus-4.1zclaude-sonnet-4-0zclaude-sonnet-4.0zclaude-opus-4-2025zclaude-sonnet-4-2025r;zclaude-opus-4.5r<zclaude-sonnet-4.5r=zclaude-haiku-4.5)r>zclaude-opus-4.6r?zclaude-sonnet-4.6)r@zclaude-opus-5-5zclaude-opus-5.5)zclaude-sonnet-5-5zclaude-sonnet-5.5rP)z ~/.local/binz~/.claude/localz~/binz~/.npm-global/binz ~/.bun/binz ~/.volta/binz/opt/homebrew/binz/usr/local/bin)rGrj)NN))r Claude Code)z Hermes agentr)z Nous Researchr))NFFNNFF>inputstore instructionsparallel_tool_calls)yrrrrloggingrqrrrr contextlibrtypingrrrrutilsragent.anthropic_credentialsr r r agent.anthropic_endpointsr r rrrrrrrragent.anthropic_message_convertrrr agent.errorsrhermes_cli.version_inforrr!r&r2 getLoggerrr1rrr~rrrrKrYrgrirkrtr{rrrrrrrrrrrrrrrrrrrrnrYrr< _OAUTH_TOOL_NAME_REVERSE_ALIASES frozenset_OAUTH_PROSE_ALIAS_NAMESrrrrrrrrrrrr'r8r@rSr[rgrorrprxrrrrrrrrrrrr.)rrrs00@r%r s/>  ,,*kk *4 154"    8 $E65(D%N  UE5'7FFHhX]_d u-)o)_%(R$-+G.9JGw 17