+ jHj< a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t H t ^RI H t HtHtHt]P"!]4t]P(RRl4tRR/RR lltR R ltR R ltRRlt/]P7R_R4C]P7R`R4C]P7RaR4C]P7RbR4C]P7RcR4Ct^tRRltRRltRRlt RRlt!RRlt"RR lt#R!R"lt$R#R$/R%R&llt%R'R(lt&RdR)R*/R+R,lllt'Ret(R-R.lt)R/RRR/R0R1llt*]+!R204t,]+!R3R404t-R5t.] !R6R744t//t0R8]1R9&]Pd!4t3R:R;lt4R<R=lt5R>R?lt6R@RAlt7RBRClt8RDRDRERDR3R3R4R3RFRF/t9RGRHlt:RIRJlt;RKRLlt]P~!RRR*RS7t@]P(RTRUl4tARdRVR/RWRXllltBRVR/RYRZlltCR[R\ltDR]R^ltER#)faLearning-loop, delegation and execution-backend shared metrics. Memory operations, curator runs, delegate_task fan-outs and terminal/browser/execute_code backend calls. Producers call the ``record_*`` functions with RAW values; every builder here maps them onto the closed enums and buckets in ``shared_metrics_contract``. Recording is a no-op unless shared metrics are enabled for the owning profile and never raises into the caller. This module imports only the stdlib at load time so tool modules can import it on their hot path. ) annotationsN) dataclassfield)AnyCallableIterableIteratorc V^8dQhRRRR/#) hermes_homerreturnIterator[None])formats"Q/home/ubuntu/.hermes/hermes-agent/hermes_cli/observability/shared_metrics_loop.py __annotate__rs * *S *^ *c#~"V'gRxR#^RIHpHpV!V4pRxV!V4R# T!T4i;i5i)z]Record in the profile captured by the producer (curator/delegation threads carry no binding).N)reset_hermes_home_overrideset_hermes_home_override)hermes_constantsrr)r rrtokens& r _bound_homers6  U $[ 1E* "5)"5)s=0 = :=r c ,V^8dQhRRRRRRRRRR /#) r mark_attrstrbuildz$Callable[..., dict[str, str] | None]r rrawr Noner)rs"rrr's:QQSQ!EQWZQjmQrvQrc ^RIHp^RIHp\ V4;_uu_4V!\ W@4V3/VBRRR4R# +'giR#;i \ d\PRTRR7R#i;i))shared_metrics_contract)_emitNzShared-metrics %s not recordedT)exc_info) r!shared_metrics_eventsr"rgetattr Exceptionloggerdebug)rrr rcontract emit_marks&&$, rr"r"'s_Q9=  % % gh2E AS A& % % % Q 5y4 PQs+A?A A AA#A:9A:c V^8dQhRRRR/#r valuerr rr)rs"rrr2s,,,,rcd\T;'gR4P4P4#)r$)rstriplowerr.s&r_normr32s% u{{  ! ! # ) ) ++rc V^8dQhRRRR/#)r resultrr dict[str, Any]r)rs"rrr6s22C2N2rc\V\4'dV#\V\\34'd\P !V4MRp\T\4'dT#/# \ \3d/u#i;iN) isinstancedictrbytesjsonloads TypeError ValueError)r5datas& r_parsedrA6sm&$ %/e %E%Etzz&!4dD))41r1 z " s4A((A>=A>cV^8dQhRR/#)r r str | Noner)rs"rrr@szrcT^RIHp\V!44# \dR#i;i)get_hermes_homeN)rrGrr'rFs r _current_homerH@s*4?$%% s  ''addreplaceremovesearchreadc V^8dQhRRRR/#r-r)rs"rrrXs77S7S7rc@\P\V4R4#other)_MEMORY_OP_WORDSgetr3r2s&r memory_oprTXs   e g 66rc$V^8dQhRRRRRR/#)r tool_namerargsr rr)rs"rrr\s!#SSrc\V\4'dVPR4MRp\V\4'd+\ V4\ 9d\ \ V4,#\ \ V4PRR4PR44FpV\ 9gK\ V,u# R#)zYThe operation a provider tool performs: its ``action`` argument, else a verb in its name.actionN-_rQ) r9r:rSrr3rRreversedrJsplit)rVrWrYwords&& rmemory_provider_opr_\s#-dD#9#9TXXh tF&#5=4D#Df ..y)11#s;AA#FG # ##D) )H rc V^8dQhRRRR/#r-r)rs"rrrgs::::rcL^RIHp\V4;'gRpW!9dV#R#)r )MEMORY_PROVIDERSbuiltinplugin)r!rbr3)r.rbnames& rmemory_provider_namerfgs&9 < $ $9D+499rcV^8dQhRR/#r r rr)rs"rrrnsKKKrc0^RIHpV!4'dR#R#)rEis_background_reviewbackground_review foreground)tools.skill_provenancerkrjs r_memory_originrons;"6"8"8 JlJrc 0V^8dQhRRRRRRRRRRRR/#) r oprprovideroutcomeorigin failure_classr dict[str, str]r)rs"rrrts8  C 3  c Z] bp rc ^RIHpHpHpHp\ V4\ V4\ V4rp W9dT MRp RV R8XdRMWR0, 9dT MRRW9dTMRR W9dT MR R V R \ V4/#) r )MEMORY_OP_FAILURE_CLASSESMEMORY_OP_ORIGINSMEMORY_OP_OUTCOMES MEMORY_OPSfailedrusuccessnoneunknownrqrQrtrmrsrr)r!rxryrzr{r3rf) rqrrrsrtrurxryrzr{ outcome_value origin_value class_values $$$$$ rmemory_op_fieldsrts}uu/4W~uV}eTaNbM%2%HMhM=I#=&vh*NNKT] B$b',"C,=(2 rc ,V^8dQhRRRRRRRRRR /#) r opsz Iterable[str]rrrrsrrur rr)rs"rrrs1   M    c  Z]  bf  rc \4p\V4R\Fp\ R\ WQW$VR7K R# \dRpL>i;i)rmNMEMORY_OP_MARK)rqrrrsrtru)ror'list_MAX_BATCH_OPSr"r)rrrrsrurtrqs&$$$ r_record_memory_opsrsR!3i( .2RY' ) s ; A  A c$V^8dQhRRRRRR/#)r rYr operationsr z list[str]r)rs"rrrs!s rc \V\4'dKV'dCVUu.uF5p\\V\4'dVP R4MR4NK7 up#\V4.#uupi)rYN)r9rrTr:rS)rYrrqs&& rbuiltin_memory_opsrsY*d## XbcXbRT jT.B.B"&&*MXbcc f  ds;A-rurc ,V^8dQhRRRRRRRRRR/#) r rYrrrsrrur rr)rs"rrrs1s]`qurc4\\W4RW#R7R#)zOne row per operation of a built-in ``memory`` tool call (a batch applies all or none). ``failure_class`` is the store's closed refusal/failure name, ``none`` on success.rcrrrsruN)rr)rYrrsrus&&$$rrecord_builtin_memory_callrs6.Grc V^8dQhRRRR/#)r r5rr boolr)rs"rrrsEECEDErc\V\4'gR#VP4R,pVPR4;'gRV9#)F:NNz{"error"z"success": false)r9rlstrip startswith)r5heads& r_provider_result_failedrs? fc " " ==?4 D ??: & D D*<*DDrraisedFc 0V^8dQhRRRRRRRRRRRR /#) r rrrrVrWr5rrr rr)rs"rrrs9##SRUimz~rcV'dRM\V4'dRMRp\\W4.Y'dRMRT;'gRR7R#)zPOne row per memory-provider tool call (plugin providers expose their own tools). exceptionprovider_errorNr|r}r~r)rrr_)rrrVrWr5rr|s&&&&$ rrecord_provider_memory_callrsC"[s++Jud4K4KEQRE!&3s1e} 77rc V^8dQhRRRR/#)r r Iterable[Any]r rr)rs"rrrsVVV3Vrc(VUu.uFp\V4NK pp\RV44pV'dV\V48XdR#V'dR#\;QJdRV4F 'gK RM RM !RV44'dR#R#uupi)c32"TF q\9xK R#5ir8)_SUCCESS_STATUSES.0ss& r %delegation_outcome..s;Fq**Fr}partialc32"TF q\9xK R#5ir8)_CANCELLED_STATUSESrs& rrrsG1#66rTFrr|)r3sumlenany)rrvalues succeededs& rdelegation_outcomersq ( )1eAhF );F;;I )s6{*#GG###GGGG;UXU *sBc ,V^8dQhRRRRRRRRRR/#)r rrrr subagentsr rvr)rs"rrrs1s3CTW\jrc ^RIHpR\V4RVRJdRMRR\T;'gR 4RT!\ V\ 4'dV4/#^4/#) r )rrmodeTrrmrssubagent_count_bucketr)r!rrrr9r)rrrrrs$$$$ rdelegation_run_fieldsrsf5 !%( d 2 %hnn"5:iQT;U;Ui!]  \]!]  rc(V^8dQhRRRRRRRR/#)r call_keyobjectrrrr rr)rs"rrrs())6))S)T)rc FV^8:dR#\W\4R7p\;_uu_4\\4\ 8d.\P \\\444KEV\\V4&RRR4R# +'giR#;i)zVOpen one delegate_task call; ``call_key`` is the object every unit of the call shares.N)rrr ) rrH_DELEGATIONS_LOCKrr_MAX_OPEN_DELEGATIONSpopnextiterid)rrrruns&$$ rbegin_delegation_runrscA~ )mo VC  ,#88   T$|"45 6%( R\"    s AB B c(V^8dQhRRRRRRRR/#) r rrresultsrrrr rr)rs"rrr s*VmTX]arc VUu.uF,p\V\4'dVPR4MRNK. pp\;_uu_4\P\ V44pVf RRR4R#VP PV4VP;'gTVn\VP 4VP8d RRR4R#\\ V4RRR4\R\XP VPVPVPVPR7R#uupi +'giL_;i)zVFold one joined unit into its call; the call's single row is emitted by its last unit.statusNDELEGATION_RUN_MARK)rrrrr )r9r:rSrrrrextendrrrr"rrr )rrrrrrs&&$ rfinish_delegation_unitr sJQR'Q:a#6#6hD@'HR  r(|, ;    H%55: s|| s|| +    H &  4s||SVS\S\>>S\\sS  s#2D<$E5-E#-EE E timeout timed_outblockedc V^8dQhRRRR/#r r@r6r rCr)rs"rrr#s77N7z7rchVPR4^|8XdR#VPR4'dR#R#) exit_codererror tool_errorNrSr@s&r_terminal_failurer#s/ xx #88G,,<6$6rc V^8dQhRRRR/#rr)rs"rrr*s:rc\VPR44pV\9d\V,#VR8Xd1VPR4'dVPR4'gR#R#)rroutputrN)r3rS_STATUS_ERROR_CLASSES)r@rs& r _code_failurer *sU 488H% &F &&$V,,TXXg..txx7I7I rc V^8dQhRRRR/#rr)rs"rrr5sWW>WjWrcbVPR4RJgVPR4'dR#R#)r}FrrNrrs&r_browser_failurer5s,88I.%7488G;L;L<VRVVrbrowsercodeterminalc ,V^8dQhRRRRRRRRRR/#)r kindrbackendr5 error_classr zdict[str, str] | Noner)rs"rrr<s1  c C  SV [p rc^RIHpHp\V4pWd9dR#\\ V4'dV!4MT4pVeTM\ V,!\ V44pRWtV,9dTMRRVfRM W9dTMRRTR VfR /#R /#) r )EXECUTION_BACKENDS_BY_KINDTOOL_ERROR_CLASSESNrrQrr~rrrsr}r|)r!rrr3r_FAILURE_CLASSIFIERSrA) rrr5rrr kind_value backend_valuefailures $$$$ rexecution_backend_fieldsr<sWtJ3x'8'8')gFM(4k:Nz:Z[bci[j:kGMPZ5[$[=ahvA^gdm 9  6>  r shared_metrics_unmetered_backend)defaultcV^8dQhRR/#)r r r r)rs"rrrRs   rc#"\PR4pRx\PV4R# \PT4i;i5i)z\Run Hermes-owned terminal/browser/code calls without counting them as execution-backend use.TN) _UNMETEREDsetreset)rs runmetered_backend_callsr%Qs9 NN4 E   sA4AA  Arc ,V^8dQhRRRRRRRRRR/#) r rrrrr5rrCr r)rs"rrr[s1  3  c Zd ps rc ^RIHp\P4'gV!4'dV#\ R\ WVVR7V#)aCount one tool call that reached its backend; returns ``result`` unchanged. ``backend`` may be a callable so resolving it costs nothing while collection is off. Calls the background review / curator forks make are Hermes' own work, not the user's (terminal.outcome skips them too).rjEXECUTION_BACKEND_MARK)rrr5r)rnrkr"rSr"r)rrr5rrks&&&$ rrecord_execution_backendr)[s?<~~/11   ":_e Mrc(V^8dQhRRRRRRRR/#)r planrr5rrCr r)rs"rrrjs/rr#rsrJrZ]rrc@VfV#\R\VRR4WR7#)zTTerminal calls that got past planning; ``plan`` is None when planning itself failed.Nrenv_typer)r)r&)r+r5rs&&$rrecord_terminal_backendr/js% | #Jj$0OQW qqrc$V^8dQhRRRRRR/#)r callz3Callable[[Callable[[Callable[[], Any]], Any]], Any]resolve_backendCallable[[], str]r rr)rs"rrrqs$Qduz}rcaa.oRVV3RllpRV3RllpV!V4p\Y$R4T# \d\TRR4hi;i)zRun one browser tool call and count it against the backend that served it. ``call`` receives a wrapper for the legacy-backend fallback: when the extension controller serves the call instead, the fallback never runs and the backend is ``extension``.cV^8dQhRR/#rhr)rs"rr)record_browser_call..__annotate__wsFFSFrc&<S'dS!4#R#) extensionr)r2served_by_legacysrr$record_browser_call..backendws$4 E+Erc V^8dQhRRRR/#)r fallbackzCallable[[], Any]r rr)rs"rrr6zs*src4<SPR4V!4#)T)append)r<r9s&rlegacy#record_browser_call..legacyzs%zrNr)r'_safe_record_browser)r1r2rr?r5r9s&f @rrecord_browser_callrBqs`FFf$/ M WdK8 s /A c(V^8dQhRRRRRRRR/#) r rr3r5rrrCr rr)rs"rrrs0OO"3OSOzO^bOrc6aRV3Rllp\RW1VR7R#)cV^8dQhRR/#rhr)rs"rr*_safe_record_browser..__annotate__s#rc8<S!4# \dR#i;irP)r')rsrre"_safe_record_browser..names" 9   s  rr.N)r))rr5rresf&& rrArAs Y+Nr) rIconcludecreateingestrememberretainsavestoreupload)editrJupdate)deleteforgetrK)probequeryreason reasoningrecallrelatedrL)contextrSrprofilerMr8)archivedcreatedmergedpatched)F__conditional_annotations____doc__ __future__r contextlib contextvarsr<logging threading dataclassesrrtypingrrrr getLoggerrr(contextmanagerrr"r3rArHr:fromkeysrRrrTr_rfrorrrrrrrrr frozensetrrrrrrLockrrrrrrr rr rrr ContextVarr"r%r)r/rBrA)ras@rrpsw# (44   8 $  * *Q]aQ,2 mm`bg mm19=   mm2H=   mm\^fg  mmA6J7:K    clEpuC"bf{m, <=  +- ',NN$8 V)*y+y-P[]j y 7W"#3V]JXij $ # #$FPU V     gk  rQUr,Or