+ jHja0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t ^RI HtHt]P !]4tR(t]!4tR]R&]P.!4tRt^@tR tR R ltR R ltRRltRRltRRlt RRlt!R)RRllt"RRlt#RRlt$RR/RRllt%R t&R!R"lt'R#R$lt(R%R/R&R'llt)R#)*aStartup / attach latency: one bucketed row per process start and surface. In-process surfaces (classic CLI, messaging gateway, ``hermes serve``) measure from the OS process creation time, the earliest timestamp available (it includes interpreter start and imports), to the moment they are ready. The Ink TUI and the Desktop app measure on their own side and report through the ``shared_metrics.startup_latency`` RPC. Recording goes through the shared ``_emit`` gate, so a profile without shared metrics enabled records nothing. ) annotationsN)Any)shared_metrics_contract)_bucket_non_negative_numberzset[tuple[int, str, str]] _recordediHERMES_RELAUNCHED_PIDc V^8dQhRRRR/#) elapsed_msrreturnz str | None)formats"T/home/ubuntu/.hermes/hermes-agent/hermes_cli/observability/shared_metrics_startup.py __annotate__r'sPPsPzPcF\V4pVfR#\V\R4#)Ngte_10s)rr_THRESHOLDS_MS)r values& rlatency_bucketr's$  ,E=4Oge^Y&OOrc$V^8dQhRRRRRR/#)r surfacerr r zdict[str, str] | Noner )rs"rrr,s"::s::@U:rcZ\V4pV\P9gVfR#RVRV/#)Nrr)rcontractSTARTUP_SURFACES)rr buckets$$ rstartup_latency_fieldsr,s0 J 'Fh///6> fi 99rc$V^8dQhRRRRRR/#)r rstrr rr Noner )rs"rrr3s&iisiiircL^RIHpV!\P\WR7R#)zORecord one measured startup (no-op unless shared metrics are on; never raises).)_emitrr N)shared_metrics_eventsr"rSTARTUP_LATENCY_MARKr)rr r"s$$ rrecord_startup_latencyr&3s, ( ' ')?hrcV^8dQhRR/#)r r z float | Noner )rs"rrr:sLrc^RIp\VP\P!44P 44# \ dR#i;i)zPEpoch seconds at which the OS created this process, or ``None`` when unreadable.N)psutilfloatProcessosgetpid create_time Exception)r)s rprocess_started_atr0:s?V^^BIIK0<<>?? s>A AAcV^8dQhRR/#r r r r )rs"rrrDs666rcl\\P!44\P\&R#)zTCalled right before an in-place ``exec``: the new program inherits this PID and env.N)rr,r-environRELAUNCHED_PID_ENVr rrmark_in_place_relaunchr6Ds%(%5BJJ!"rcV^8dQhRR/#r r boolr )rs"rrrIsBBdBrc\PP\4\ \P !448H#)N)r,r4getr5rr-r rr_relaunched_in_placer<Is& ::>>, -RYY[1A AArc$V^8dQhRRRRRR/#)r rr launch_idr r9r )rs"rrrNs!CCrc\P!4W3p\;_uu_4V\9g\ \4\ 8d RRR4R#\P V4RRR4R# +'giR#;i)NFT)r,r-_lockrlen _MAX_RECORDEDadd)rr>keys&& r_claimrENsQ 99; +C  ) s9~>   c s%A5A55 B cV^8dQhRR/#r8r )rs"rrrWsTrc^RIHpV!4#)enabled)relay_shared_metricsrJrIs r_collection_enabledrLWs - 9rc$V^8dQhRRRRRR/#)r rrready_atr*r r r )rs"rrr]s&````$`rcn\4pVe'\V\RW, 4R,R7R#R#)Ngr#)r0r&max)rrNstarteds&& r_record_since_process_startrS]s/ "Gw3sHDV;WZ^;^_r backgroundFc$V^8dQhRRRRRR/#)r rrrTr9r r r )rs"rrrcs&TT#TdTtTrc\P!4p\4'g"\V4'd\4'gR#V'g\ W4R#\ P !4p\P!VP\W3RRR7P4R# \d\PRTRR7R#i;i)a,``surface`` became ready now: record process-start -> now once per process. ``background`` hands the (possibly cold, ~seconds) metrics runtime start to a daemon thread under the caller's contextvars (profile binding), so an event loop never waits on it; the ready time is taken before the hand-off. Nzhermes-startup-latencyT)targetargsnamedaemonz#Startup latency for %s not recorded)exc_info)timer<rErLrS contextvars copy_context threadingThreadrunstartr/loggerdebug)rrTrNcontexts&$ rrecord_process_readyrfcsyy{H T  ! !@S@U@U  ' : **,;;&A7%U)$  %' T :Gd STs$1B. B. B.A B..#CCcRRlpV#)zVA prompt_toolkit ``after_render`` handler that records the first rendered prompt once.c V^8dQhRRRR/#)r _apprr r r )rs"rr.cli_prompt_ready_handler..__annotate__~s5555rc \RRR7R#)cliT)rTN)rf)ris&r _on_render,cli_prompt_ready_handler.._on_render~s Ut4rr )rms rcli_prompt_ready_handlerro{s5 rcV^8dQhRR/#r2r )rs"rrrs$$4$rcj\PPR4'g\R4R#R#)zA ``-q`` run is ready to dispatch its query. Kanban workers are dispatched processes, not a user waiting on a prompt, so they stay out of the CLI startup distribution.HERMES_KANBAN_TASKrlN)r,r4r;rfr rrrecord_cli_one_shot_readyrss% ::>>. / /U# 0rc V^8dQhRRRR/#)r r>rr rr )rs"rrrsdd3d3drc^\V\4'd\V4\8:dV#R#)zThe client's per-launch id, only ever a local latch key (never recorded). Older clients send none and latch on their side; they count once per backend process and surface.) isinstancerrA_LAUNCH_ID_MAX_LEN)r>s&r _launch_keyrys(#9c22s9~I[7[9caccrr>c(V^8dQhRRRRRRRR/#)r client_surfacerr r>r r r )rs"rrrs0GG#G3GSVGbfGrcRRRRRR/PV4pVe;\V4e,\V\V44'd\ W1R7R#R#R#R#)zThe TUI / Desktop client's own launch -> ready measurement, once per (surface, client launch) in this backend process. ``client_surface`` is the client's declared surface or the backend's detection (``desktop``/``tui``); anything else records nothing.desktopdesktop_attachtuiNr#)r;rrEryr&)r{r r>rs$$$ rrecord_rpc_startup_latencyrs`*,<>NPUW\]aabpqG~j9E&QXZefoZpJqJqwFKrEr))ilt_500ms)rP 500ms_to_1s)i1s_to_2s)i2s_to_5s)i' 5s_to_10s)rv)*__conditional_annotations____doc__ __future__rr]loggingr,r_r\typingrrvrrrr getLogger__name__rcrsetr__annotations__Lockr@rBrxr5rrr&r0r6r<rErLrSrfrorsryr)rs@rrs#  1B   8 $ (+u $, -P :i6 B  ` TUT0$d GY]GGr