Pmj7AUdZddlmZddlZddlmZddlmZddlm Z dZ dZ d Z d Z d Zd Zd ZdZdZehdZded<ehdZded<ehdZded<ehdZded<ehdZded<ehdZded<ehdZded<ehdZded <ehd!Zded"<ehd#Zded$<ehd%Zded&<eeeheeeed'eeed(eeeeeeeeeed) iZ d*ed+<ee Z!ded,<ej"d-d.#d/e$ed0hz d1d23Dzd4zZ%ehd5Z&ed6d7hZ'ddd>Z(dedBZ)dfdDZ*dgdFZ+dhdHZ,didjdKZ-dkdQZ.dldSZ/dmdTZ0dndVZ1dgdWZ2dodZZ3ed[\dpd]Z4dgd^Z5dqd`Z6dhdaZ7dgdbZ8dgdcZ9dS)rzCBounded product contract for the first Hermes shared-metrics slice.) annotationsN) lru_cache)Any)RUNTIME_INSTANCE_KEYzhermes.metrics.schema_versionzhermes.metrics.event.v1zhermes.model_callzhermes.task_runz hermes.nemo_relay.shared_metricsprimaryzhermes.model_call.countzhermes.task_run.startedzhermes.task_run.finished> apiclituibatchotherpythondesktopgatewayunknownscheduled_taskfrozenset[str]EXECUTION_SURFACES>localcustomdirectr aggregatorPROVIDER_FAMILIES>rremoterMODEL_LOCALITIES>failedsuccess cancelledMODEL_OUTCOMES>rrrr timed_out TASK_OUTCOMES> rr completedrsystem_aborteduser_cancelledapproval_deniediteration_limitguardrail_blockedTASK_END_REASONS>nonerrr"r#TASK_TERMINATIONS> rr r r r delegated background interactivergateway_messageTASK_ENTRYPOINTS>lt_1sgte_10m1s_to_5s 2m_to_10m 30s_to_2m 5s_to_30sDURATION_BUCKETS>0123_to_5gte_116_to_10 COUNT_BUCKETS>o1o3o4glmgptgrokkimimimonovaqwenstepgemmallamaclaudegeminiminimaxmistraltrinityrdeepseeknemotronMODEL_FAMILIES call_rolelocality model_familyoutcomeprovider_family entrypointexecution_surface) duration_bucket end_reasonrYrZmodel_call_count_bucketrVretry_count_bucket terminationtool_call_count_bucketz$dict[str, dict[str, frozenset[str]]]_COUNTER_DIMENSION_VALUESCOUNTER_METRICSz(?:^|[/_.:-])(|c#>K|]}tj|VdSN)reescape).0familys V/home/thesage/.hermes/hermes-agent/hermes_cli/observability/shared_metrics_contract.py rks@  &rc t|Sre)len)values rjrps c%jjrlT)keyreversez)(?=$|[/_.:-]|\d)> copilot-acpgithub-copilotmoanousmlxollama metric_namestr dimensionsdict[str, Any]returnboolct|}| tt|krdStfd|DS)zBReturn whether dimensions match one closed shared-metric contract.NFc3hK|],\}}t|to ||vV-dSre) isinstancerz)rhfieldallowed_valuesr{s rjrkz/counter_dimensions_are_valid..s^ "E> :e$c** 0 u  /rl)ragetsetallitems)ryr{contracts ` rjcounter_dimensions_are_validrs} ),,[99H3z??c(mm;;u &.^^%5%5  rleventrdict[str, str] | Nonecxt|dd}t|tr#|tt krdSt |tthz }|dhz s|dddvrdStt|ddpddksqtt|d dpdd ksMtt|d dpdtks$tt|d dpdd krdSt|dd}t|trt |dhkrdS|d}|tvrdSt|dd}hd}t|trt ||krdS|d|d|d|d|dd}tt|sdS|S)zEReturn package dimensions for one valid primary model-call end event.metadataNotel.status_codeOK>rERRORkindscopecategoryllmnamescope_categoryendcategory_profile model_namedata>rVrTrSrUrWrSrTrUrVrWrR) getattrrdictr SCHEMA_KEYSCHEMA_VERSIONrrrzMODEL_CALL_SCOPErQrMODEL_CALL_METRIC)rrrelay_metadatarevent_model_familyrexpected_fieldsr{s rjmodel_call_dimensionsrsYuj$//H h % %j)A)A^)S)St]]j2F%GGN+,, D11 11t GE62 & & ,"--88 wuj"--3 4 4 = = wufb))/R 0 04D D D wu.339r : :e C Ctu&8$?? & - -5E1F1FK22t)--l;;//t 5&$ ' 'DO dD ! !SYY/%A%AtXXk**HHZ((0088I&&88$566 J ((9: F Ft rl!tuple[str, dict[str, str]] | Nonec`t|dd}t|tr#|tt krdSt |tthz }|dhz s|dddvrdStt|ddpddksMtt|d dpdd ks)tt|d dpdtkrdSt|d ddStt|d dpd}t|dd|dkryddh}ttrt |krdSddd}tt|sdSt|fShd}|dks(ttrt |krdSfdt|D}tt|sdSt|fS)z:Return one validated task counter from a task scope event.rNrr>rrrrrrfunctionrrrrstartrYrZrX> rVr\rYr_r[rZr^r`r]rc<i|]}||S)r)rhrrs rj z task_counter..!s%NNNU%%NNNrl)rrrrrrrrrz TASK_SCOPErTASK_STARTED_METRICsortedTASK_FINISHED_METRIC)rrrrrr{rs @rj task_counterrsauj$//H h % %j)A)A^)S)St]]j2F%GGN+,, D11 11t GE62 & & ,"--88 wuj"--3 4 4 B B wufb))/R 0 0J > >tu($//;t(8"==CDDN 5&$ ' 'D  ')<=$%% To)E)E4((<00!%*=!>!>  ,,?LL 4"J..   O %$%% t99 ' 'tNNNNf_6M6MNNNJ '(cron scheduled schedulerrr)get_all_platformsr>emailslackteamsdiscordtelegramwhatsappr )rzrstriplowerrhermes_cli.platformsr Exception)rrors rjrZrZ's FJJ* + + Rvzz*/E/E RSS    """  u 222 :::::: %%'' ' '9 (       NNNy**997s8B BBdict[str, str]cFt|}t|||dS)z>Build the bounded fields recorded on a task scope start event.rX)rZtask_entrypoint)rsurfaces rjtask_start_fieldsr@s.''G%fg66$  rlr str | Nonec bt|dpd}|tvr|S|pt |}|ds|drdSddddd d d dd d |dS)zCNormalize the task dispatch owner without exporting source strings.rYrparent_task_idparent_session_idr*rr r,r-r rr) rr r rrr rr rr )rzrrrr.rZ)rrdeclaredresolved_surfaces rjrrIs6::l++1r2288::@@BBH###;"3F";"; zz"##vzz2E'F'F{ $*   c G$$ %rl duration_msintmodel_call_counttool_call_count retry_countc t|}t|\}}}i|t||t||t||t|dS)z6Build the bounded terminal payload for one task scope.)r[r\r]rVr^r_r`)rtask_terminal_stater[ count_bucket) rrrrr start_fieldsrVr\r_s rjtask_terminal_fieldsr^s|%V,,L':6'B'B$GZ   *;77 #/0@#A#A*;77""."?"?    rltuple[str, str, str]ct|dpd}|dsd|vsd|vrdSd|vsd|vrd Sd |vsd |vrd Sd |vr d|vsd|vrdSd|vrdS|dkrdS|ddurdS|ddus|r|dkrdSdS)z=Map Hermes terminal state to bounded task outcome dimensions.turn_exit_reasonr interrupted interruptcancel)rr#r#timeoutr)rrrmax_iterationsbudget_exhausted)rr%r"approvaldeniedrejected)rr$r( guardrail)rr&r"r")rr"r"r!T)rr!r(rr)rrr()rrr)rzrrr)rreasons rjrrus5 .//52 6 6 < < > > D D F FF zz-  ?K6$9$9X=O=O>>FkV33446!!%76%A%A<<VV!3!3zV7K7K22f>> !!!;; zz+$&&-- zz(t###6Y3F3F)) * *rlctdt|}|dkrdS|dkrdS|dkrdS|dkrd S|d krd Sd S) zGBucket a non-negative task duration into a fixed low-cardinality range.rir/ir1i0ur4ir3i' r2r0)maxr)rros rjr[r[sd 3{## $ $E u}}w u}}z v~~{ w{ w{ 9rlcountctdt|}|dkrt|S|dkrdS|dkrdSdS)z8Bucket a non-negative per-task count into a fixed range.rr9 r;r:)rrrz)rros rjrrsM 3u::  E zz5zz zzx {{y 8rlczt|dpddd}|sdS|t vrdS|dks|drdSt|\}}}|d vrdS|s |tvrd S|dkrdS|rd ndS) z4Map a Hermes provider to a bounded product category.providerr_-rrr)zcustom-zcustom:>rlmstudiorr) rzrrrreplace_LOCAL_CUSTOM_PROVIDER_ALIASES startswith_provider_metadata_TELEMETRY_AGGREGATOR_OVERRIDES)r raw_providerr is_aggregatoris_knowns rjrWrWsvzz*--344::<<BBDDLLSRUVVL y555wx<#:#:;Q#R#Rx(:<(H(H%HmX(((w$CCC|8x .88Y.rlrtuple[str, bool, bool]c ddlm}ddlm}m}|||}||}|t |o|j|tvfS#t$r|ddfcYSwxYw)zFResolve provider identity without refreshing remote provider metadata.r)normalize_provider)HERMES_OVERLAYSrF) hermes_cli.modelsrhermes_cli.providersrrr~r_known_provider_idsr)rnormalize_model_providerrr canonicaloverlays rjrrs &TTTTTTLLLLLLLL&&'?'?'I'IJJ !%%i00  2W2 3 3 ,.. .  &&&%%%%&sAA A21A2)maxsizecz ddlm}t|S#t$rtcYSwxYw)z@Cache Hermes's static provider catalog for the process lifetime.rprovider_catalog_by_slug)hermes_cli.provider_catalogr  frozensetrrs rjrrs\HHHHHH1133444 {{s ::c<t|t|S)z5Classify local endpoints without exporting their URL.)_model_localityrW)rs rjmodel_localityrs 6?6#:#: ; ;;rlprovider_categoryc|d}t|tr'|r% ddlm}||rdSn#t $rYnwxYw|dkrdS|dvrdSdS)Nbase_urlr)is_local_endpointr>rrrr)rrrzagent.model_metadatarr)rrrrs rjr r szz*%%H(C  X  > > > > > >  ** w     D G##w444x 9sA AAcnt|}tt||t||dS)z=Build the bounded producer fields for one logical model call.)rSrTrUrW)rWPRIMARY_MODEL_CALL_ROLEr rU)rrs rjmodel_call_fieldsrs>'//,#F,=>>$V,,,   rlct|dpd}|tdhz vr|St|dp|dpd}t |}||dndS)z4Map a raw model identifier to an allowlisted family.rUrrresponse_modelmodelNr)rzrrrrQ_MODEL_FAMILY_PATTERNsearchgroup)rdeclared_familyrmatchs rjrUrUs&**^44:;;AACCIIKKO.I;666  +,,I 70C0CIr J J P P R RE ! ( ( / /E".5;;q>>>I=rlct|dpd}|tvr|ndS)zAFail closed when a terminal model-call outcome is not recognized.rVrr)rzrrr)rros rjmodel_call_outcomer s@  9%%+ , , 2 2 4 4E^++559rl)ryrzr{r|r}r~)rrr}r)rrr}r)rr|r}rz)rr|r}rre)rr|rrr}rz) rr|rrrrrrrrr}r)rr|r}r)rrr}rz)rrr}rz)rrzr}r)r}r)rr|rrzr}rz):__doc__ __future__rrf functoolsrtypingragent.relay_runtimerrrrrSUBSCRIBER_NAMErrrrr r__annotations__rrrr r'r)r.r5r<rQrarbcompilejoinrrrrrrrrZrrrrr[rrWrrrr rrUr rrlrjr*sIII"""""" 444444 , *&  4#-/1%.Y 0 0 0 & &    %.I///%%$-9-K-K-K#L#LLLLL!*+M+M+M!N!NNNNN ) +++!! $-9 . . . $ $    %.I///%%$-9 . . . $ $    $-9...$$!* +++!! "+,,,""2Y 7899$&!, &/+&&/#0 +("/  C0#,),E"F"FFFFF"  hhf i[ (((       #,)---##"+E8+>>>::::::rl