+ lHjARt^RIt^RIt^RIt^RIt^RIHtHt^RIH t H t ^RI H t ^RI Ht^RIHt]P$!R4tRt!R R 4tR#) zSession health for MCPServerTask: dynamic tool refresh on list_changed notifications, server log forwarding, keepalive probes, suspect-mark / lazy-verify, in-flight call fail-fast, stdio child liveness and stdio idle/lifetime recycling.N)IterableOptional)_is_method_not_found_error_unwrap_exception_group)mcp_prefixed_tool_name)_core)mcp_tool_registrationztools.mcp_toolg>@cha]tRt^toRtR(tV3RlRltV3RlRltV3RlRltV3RlR lt R t R)V3R lR llt V3RlRlt V3RlRlt V3RlRltRtRtV3RlRltRtV3RlRltV3RlRltV3RlRltR*V3RlR lltV3R!lR"ltV3R#lR$ltV3R%lR&ltR'tVtR #)+MCPServerHealthMixinzVMethods of :class:`tools.mcp_tool.MCPServerTask` (mixed in; relies on its attributes).c <V^8dQhRS[/#returnbool)format __classdict__s":/home/ubuntu/.hermes/hermes-agent/tools/mcp_tool_health.py __annotate__!MCPServerHealthMixin.__annotate__s%%$%c RVP9#)url)_configselfs&r_is_httpMCPServerHealthMixin._is_https $$rc <V^8dQhRS[/#r r)rrs"rrrsIIDIrc XVP4'*;'dVPRJ#)z4True when a stdio server was intentionally recycled.N)r_recycled_reasonrs&r_is_recycled_stdio'MCPServerHealthMixin._is_recycled_stdios$==?"HHt'<'BNcF<V^8dQhRS[S[,RS[S[,/#)r nowr)rfloatstr)rrs"rrr0s'oo%oHSMorc aSf\P!4MSo\V3RlVP44R4#)zTThe stdio recycle reason if idle/age limits have elapsed (lifetime wins), else None.Nc3><"TFwrSV8gKVxK R#5ir.r%).0deadliner<r@s& r =MCPServerHealthMixin._stdio_recycle_reason..3s!g4S 0WZ^fWfVV4Ss  )r'r(nextr=)rr@s&fr_stdio_recycle_reason*MCPServerHealthMixin._stdio_recycle_reason0s2"%+dnn3gD4Q4Q4Sgimnnrc0<V^8dQhRS[S[,/#r )rrA)rrs"rrr5sRRhuoRrcF\RVP44RR7#)c3*"TF wrVxK R#5ir.r%)rEd_s& rrGDMCPServerHealthMixin._next_stdio_recycle_deadline..6sB"A$!A"AsN)default)minr=rs&r_next_stdio_recycle_deadline1MCPServerHealthMixin._next_stdio_recycle_deadline5sB$"?"?"ABDQQrc$<V^8dQhRS[RR/#r r<rNrB)rrs"rrr8s34rc WnRVnR#)zCMark a stdio session dormant before its transport finishes closing.N)r sessionrr<s&&r_mark_stdio_recycled)MCPServerHealthMixin._mark_stdio_recycled8s & rc4<V^8dQhRS[P/#r )asyncioTask)rrs"rrr=s   rc aV3Rlp\P!V!44pSPPV4VP SPP 4V#)zUSchedule a background tool refresh (failures logged) and keep it strongly referenced.c<"SP4GRjxL R#L \d%\PRSP4R#i;i5i)Nz,MCP server '%s': dynamic tool refresh failed)_refresh_tools Exceptionlogger exceptionnamersr_run:MCPServerHealthMixin._schedule_tools_refresh.._run?sF \))+++ \  !OQUQZQZ[ \s1A!!A!+A AAA)r_ create_task_pending_refresh_tasksaddadd_done_callbackdiscard)rrhtasksf r_schedule_tools_refresh,MCPServerHealthMixin._schedule_tools_refresh=sP \ ""46* ##''- t::BBC rc aV3RlpV#)a``logging_callback`` forwarding server ``notifications/message`` into Hermes logging (SDK default drops them). Routes MCP ``notifications/message`` log notifications from the server into Hermes' logging (agent.log via hermes_logging), tagged with the server name. Without this, the SDK's default callback silently discards them, so server-side warnings/errors during a tool call were invisible. Port of anomalyco/opencode#34529. c <"\PP\\ VRR44P 4\ P4p\ VRR4p\V\4'g\P!VR\R7p\V4R8dVR,R,p\ VR R4pV'dSP R V 2M SPp\P!VR WB4R# \\3d\T4pLi;i \"d'\P%R SPR R7R#i;i5i)levelinfodataNF) ensure_asciirRi:NiNz... [truncated]re/zMCP server log [%s]: %sz/Failed to handle MCP log notification from '%s'T)exc_info)r_MCP_LOG_LEVEL_MAPgetrBgetattrlowerloggingINFO isinstancejsondumps TypeError ValueErrorlenrgrelogrddebug)paramsrtrv logger_nameoriginrs& r_on_log._on_logQs j0044SRX9Y5Z5`5`5bdkdpdpqvvt4!$,,)#zz$UCPt9t#;)::D%fh= 9DDII;a }5$)) 5";VJ &z2)"4y) j NPTPYPYdh i jsNEA3D#9DA)D#?ED D#D  D##-EEEEr%)rrsf r_make_logging_callback+MCPServerHealthMixin._make_logging_callbackIs j rc aV3RlpV#)zj``message_handler``: only ``ToolListChangedNotification`` triggers a refresh; prompt/resource changes log.c^<"\V\4'd$\PRSPV4R#\ P 'd!\V\ P4'gR#\VRV4p\V\ P4'dQ\PRSP4SP4\P!^4GRjxL R#\V\ P4'd#\PRSP4R#\V\ P4'd#\PRSP4R#R#L \d%\P!RSP4R#i;i5i)z'MCP message handler (%s): exception: %sNrootz9MCP server '%s': received tools/list_changed notificationz/MCP server '%s': prompts/list_changed (ignored)z1MCP server '%s': resources/list_changed (ignored)z%Error in MCP message handler for '%s')rrdrerrgr_MCP_NOTIFICATION_TYPESServerNotificationr|ToolListChangedNotificationrurpr_sleepPromptListChangedNotificationResourceListChangedNotificationrf)messagepayloadrs& r_handler._handleres0 Ugy11LL!JDIIW^_555*WeNfNf:g:g"'67;gu'H'HIIKK []a]f]fg002!--***)L)LMMLL!RTXT]T]^)N)NOOLL!TVZV_V_`P+  U  !H$))T UsqF-7E;F-E; E;4F-6A6E;,E9-E;1F-3AE;3F-5AE;5F-9E;;+F*&F-)F**F-r%)rrsf r_make_message_handler*MCPServerHealthMixin._make_message_handlercs U,rc4<V^8dQhRS[S[,RR/#)r tool_namesrN)rrB)rrs"rrr}s#OOHSMOdOrc ^RIHpVF>pVPV4RVP 28XgK(\P !W4K@ R#)zjDeregister *tool_names* this server's toolset still owns (never a colliding name owned by another server).)registryzmcp-N)tools.registryrget_toolset_for_toolrg _registration_deregister_mcp_tool_all_scopes)rrr tool_names&& r_deregister_owned&MCPServerHealthMixin._deregister_owned}s;+#I,,Y7T$));MM==dN$rc "\VRR4eR#VP4'gR#VP;_uu_4GRjxL \VP4pVP ;_uu_4GRjxL VP pVfD\PRVP4RRR4GRjxL RRR4GRjxL R#\P!VPRVP4GRjxL pRRR4GRjxL TPTXUu0uF#p\VPVP4kK% up, 4W0n\ P"!VPWP$4pVPV\V4, 4WPn\V4pRWa, 3RW, 33UUu.uF.wrxV'gKV RRP'\)V44 2NK0 p ppV 'd2\P+R VPR P'V 44M4\P-R VP\/VP44RRR4GRjxL R#ELDELELELELEL +GRjxL 'giEL;iuupiuuppiL@ +GRjxL 'giR#;i5i) uRe-fetch tools on ``tools/list_changed`` and update the registry. The lock serializes rapid-fire notifications; after the list_tools ``await`` all mutations are synchronous — atomic on the event loop._editor_frozen_manifestNzEMCP server '%s': skipping dynamic tool refresh; session not connectedtoolsaddedremovedz: z, uUMCP server '%s': tools changed dynamically — %s. Verify these changes are expected.z; z>MCP server '%s': dynamically refreshed %d tool(s) (no changes))r|_advertises_tools _refresh_lockset_registered_tool_namesr5rZrerrgr_paginate_full_list list_toolsrr_toolsr_register_server_toolsrjoinsortedwarningrur) rold_tool_namesrZ new_mcp_toolstoolregistered_namesnew_tool_nameslabelnameschangess & rrc#MCPServerHealthMixin._refresh_toolss5 42D 9 E %%'' %%%% !n{4|n{fj5KDIIW[W`W`5an{4|#| }(K,CCDIItUaUab   " ">C8H4I#I J*: ' !12N ."ABYP^PoDpq|qCO%uz>%499VE]#;"<=q | DEIYYPTPYPYZaPbd \ IIs4+F+F'GI;&%%%&!h&~~~5}|/&%%%s'K!K!JK!.K6J 7K:2J , K7J8K< K!JK!/J =J >J  K JK")J7 BK J< ##J< A0K6 K!KK! KKK!J KJ4 J#! J4 ,J4 .KK!K K  K K  K!c<V^8dQhRR/#r$r%)rrs"rrrsrc a"V3RlpSP'g@\P!SPP 4\ R7GRjxL R#V!4GRjxL R#L \ dp\T4'dDSP4'ghRSn\PRSP4Rp?Lr\T\\P34'dhSP4'dRT!4GRjxL M \ dTRhi;iRSn\PRSP4Rp?R#hRp?ii;iL5i)aExercise the session; raise on a genuine connection failure. ``ping`` first (cheap, OPTIONAL); on -32601 latch ``_ping_unsupported`` (reset per transport connection) and fall back to ``list_tools`` when the server advertises tools, else the -32601 propagates.c<"\P!SPP4\R7GRjxL R#L5i)timeoutN)r_wait_forrZr_KEEPALIVE_RPC_TIMEOUTrsrr9MCPServerHealthMixin._keepalive_probe..list_toolss*""4<<#:#:# \dp\T4p\PRTPT\T4PT4RTnTPRT 24RTnTPP!4TPP4Rp?R#Rp?ii;i5i)zVerify a suspect connection before reuse; recycle if dead. True when healthy (suspicion cleared). On failure requests a reconnect, drops the stale session so the caller's no-session path takes over, and returns False. Never raises.TNFru|MCP server '%s': suspect connection (%s) failed health check (%s: %s) — requesting reconnect (state: suspect → degraded)zhealth check failed after uSMCP server '%s': suspect connection passed health check (%s) — clearing suspicion)rrZ_reconnect_eventrr_rrrdrrerrgtype__name__r_readyclearrur)rrr<rrs&& rensure_healthy#MCPServerHealthMixin.ensure_healthys)%% << #'D  ! ! % % ' ""4#8#8#:GL L L  iIIv '# !!#! M *3/D NNP99fd4j.A.A4 I$(D    :6(C DDL KK     ! ! % % ' sCAE% )B54B35B59:E%3B55 E"BEE%E""E%c$<V^8dQhRS[RR/#rWrX)rrs"rrr s  3 4 rc VPUu.uFq"P4'dKVNK ppV'gR#R;VnVnVP V R\ V4 R24VFpVP 4K R#uupi)a<Cancel every in-flight RPC BEFORE the transport unwinds: the SDK does not always fail pending requests when streams close, so a call would otherwise wait out the full tool timeout. Cancelling anything flags ``_teardown_race`` so run() treats the next reconnect as recovery rather than charging the rapid-drop budget.NTz tore down z in-flight call(s))_inflight_tasksdone _reconnectingrrrcancel)rr<tvictimsros&& r_fail_inflight_calls)MCPServerHealthMixin._fail_inflight_calls sw #22C2&&(112C 377T0 VHKG ~=OPQD KKM Ds BBc <V^8dQhRS[/#r r)rrs"rrrs  d rc a\VRR4pV'dVP4'dR#^RIo\;QJd)V3RlV4F'gK R'*# R'*#!V3RlV44'*# \dR#i;i)uTrue when every stdio child we spawned has exited. Best-effort: False (unknown → don't fail fast) for HTTP, no captured PIDs, missing psutil, or a failed probe._stdio_child_pidsNFc3F<"TFpSPV4xK R#5ir.) pid_exists)rEpidpsutils& rrG.sBTc6,,S11Ts!T)r|rranyrd)rpidsrs& @r_stdio_children_dead)MCPServerHealthMixin._stdio_children_deadspt0$7t}}  sBTBssB BsB BsBTBBB B  s(A=A=A=A='A== B  B c<V^8dQhRR/#r$r%)rrs"rrr"s&&T&rc ~"VP4'g!\P!R4GRjxL K6R#L5i)zwPoll child liveness during a stdio RPC; resolves when a tracked child dies so the caller cancels the RPC. See #81995. g?N)rr_rrs&r_watch_stdio_children*MCPServerHealthMixin._watch_stdio_children"s0 ++----% % %. %s==; =)r)r/rrrrrr rrrrrrrZr%r.)g@)r __module__ __qualname____firstlineno____doc__ __slots__rr!r*r0r=rJrTr\rprrrrcrrrrrrr__static_attributes____classdictcell__)rs@rr r s`I%%II33%%aoo RR  44OO%IN@AA* . .<    &&rr )rr_rr~r'typingrrtools.mcp_tool_errorsrrtools.mcp_tool_schemartools.mcp_tool_commonrrrr getLoggerrerr r%rrrsJ5  %U8'8   + ,U&U&r