+ Wj0a0t$Rt^RIHt^RIHt^RIt^RIt^RIt^RI t ^RI t ]P!] 4tRtRtRtRt]P&!4tRsR]R&/tR ]R &R R ltR RltRRltRRltRRltRRltRRltRRltRRlt R#)uLive model-load progress from the managed llama-server router. Children emit per-tensor progress ({stages, current, value}) which the router relays ONLY over its /models/sse stream — GET /models carries just the coarse status. The watcher starts on first call, reconnects with backoff (the router bounces on download/eject), and never raises into callers: no router, no state file, or no SSE support (older engines) all read as "nothing loading". ) annotations)suppressNg333333?g@g^@zthreading.Thread | None_watcherdict[str, dict] _snapshotc V^8dQhRRRR/#)xfloatreturnint)formats"ZC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\local_runtime\load_progress.py __annotate__rs,,E,c,c N\^\^d\V^d,444#))maxminround)r s&r_pctrs q#c5S>* ++rc(V^8dQhRRRRRRRR/#) rstagesz list[str]currentstrvaluer r r r )rs"rrr"s(  y 3 u  rcxV'dW9g\V4^8Xd \V4#VUu.uF q3R8wgK VNK ppV'dR\, \V4, MRpRpVF:pVR8Xd\MTpWq8Xd\WhV,,4u#Wh, pK< \V4#uupi)z=Map (stage, in-stage value) onto one 0-100 range, text-heavy. text_modelg?)lenr_TEXT_STAGE_SHARE) rrrsextras extra_shareoffsetstageshares &&& r_composite_percentr("s W*c&kQ.>E{ 5A #4aaF 5=C3**c&k9K F%*l%:!   ./ /  ;6s B7B7cV^8dQhRR/#)rr ztuple[str, str] | Noner )rs"rrr1s)rc^RIHpV!4#)zU(base_root, api_key) of the managed router via the ownership-guarded reader, or None. managed_root)!hermes_cli.local_runtime.endpointr,r+s r _endpointr.1s > >rc(V^8dQhRRRRRRRR/#)rmodelreventdatadictr Noner )rs"rrr8s('''C't''rc \;_uu_4\VPRR44pV\9EdVR8XEdVPR4;'g/pVPR4;'g.Uu.uFp\V4NK pp\VPRR44pVPR4p\P VRRRRR ^R R/4p \ P!4V R &V'dG\V\\34'd+WyR&\V4V R&\Wg\V44V R &M-V.\OR N59dVR8wd\PVR 4R R R 4R #uupi +'giR #;i) statusloadingprogressrrrr&rpercentts model_removeN) _lockrget _LOAD_EVENTSr setdefaulttime monotonic isinstancer r r(pop) r0r1r2r6r9r"rrrentrys &&& r _apply_eventrF8sD TXXh+, L Vy%8xx +11rH'/||H'='C'C'CE'Cc!f'CFE(,,y"56GLL)E(("gsIWXZ^`c0deE..*E$K:ec5\::!(g!&ug#5fuU|#Ti 5 5n5 5&I:M MM% & F s+AE:E:2E:7E5 C E:5E:: F cV^8dQhRR/#rr r4r )rs"rrrKsrc\;_uu_4\P4RRR4R# +'giR#;i)N)r=rclearr rr_clear_snapshotrKKs  s. ? cV^8dQhRR/#rHr )rs"rrrPs ' ' 'rc \4pVf'\4\P!\4K5Vwr\ P PV R2RRV 2RR/R7p\ P PV^ Exceptionloggerdebug) endpointbasekeyreqrbufchunklinetextmsgexcs r_watchrtPs ;     JJ) *   D..((D6)=73%(DDF#w77$%d&:&:IFF"&**T"X^^-=">C(SWWWb-A)BCPWY[H\D]),)>)>B@GF9(  %&GFF98  D LL=s C C Ds\AH;?H(H("A3H(BH  H($H; H%  H(( H8 3H;8H;; I&I!!I&cV^8dQhRR/#rHr )rs"rrrssrc\;_uu_4\e\P4'g2\P!\ RRR7s\P 4RRR4R# +'giR#;i)NTzllamacpp-load-progress)targetdaemonname)r=ris_alive threadingThreadrtstartr rr_ensure_watcherr~ssF   8#4#4#6#6 ''vdIabH NN  s"A-1A-- A> cV^8dQhRR/#)rr rr )rs"rrr{sUUoUrcb\4\P!4p\;_uu_4\P 4UUu/uF=wrWR,, \ 8gKVRVR,RVR,RVR,/bK? uppuuRRR4#uuppi +'giR#;i)z{model_id: {"stage", "value", "percent"}} for models loading right now. Empty when nothing is loading (or nothing is knowable).r;r&rr:N)r~rArBr=ritems_STALE_ENTRY_TTL_S)nowmes rget_loading_progressr{s .. C %OO-U-DAwAS1SWGQwZ!G*i9VV-U U s#BB '"B BB B. c V^8dQhRRRR/#)rr0rr z dict | Noner )rs"rrrs555 5rc \4pVfR#^RIHpHpV!.VORV!V4 2N5R^/p^p\ T\ 4'dTM.Fmp\\\4;_uu_4TPR4'd/\T\TPR4;'g^44pRRR4Ko T^8dRT/#R# \dR#i;i +'giK;i)u{"processed": tokens} while the managed server is prompt-processing for ``model``, or None (idle, decoding, unreachable, or foreign server). /slots exposes ``n_prompt_tokens_processed`` but no total, so callers supply the denominator. The busiest processing slot wins: a parallel small request freezes its counter during decode while a live prefill keeps climbing. One HTTP call per poll; every failure reads as "no prefill" — garnish, never load-bearing. N) child_querymanaged_get_jsonz/slots? timeout_s is_processingn_prompt_tokens_processed processed) r.r-rrrfrClistrrd ValueErrorr>rr )r0eprrslotsbestslots& rget_prefill_progressrs B zS R"R E0B/C&DRPQR D#E400b8 i , ,xx((4TXX.I%J%O%Oa!PQ- ,9#'(K 44 - , ,s#C +:C& C CC C- ) status_change model_status)!__conditional_annotations____doc__ __future__r contextlibrrbloggingr{rAurllib.requestrX getLogger__name__rgr!rWrr?Lockr=r__annotations__rrr(r.rFrKrtr~rr)rs@rrs#     8 $0 $( !( ?, '& 'FU5r