+ lHjMRt^RIHt^RIt^RIHt^RIHtRRltRRlt R t R R lt R!t R R lt RRltRRlt!RR]4t!RR]4t]P&RRl4tR"RRlltRRRR/RRlltRR ltR#)#aLive compression: config hot-reload onto a running agent, pending model switch apply, /compress (CompressionLockHeld when a turn holds the lock), session-key sync after compress. Bodies are rebound onto server.py's globals (method_ctx.bind_module) and reference them bare.) annotationsN)is_truthy_value) bind_modulec V^8dQhRRRR/#)cfg dict | Nonereturntuple)formats"D/home/ubuntu/.hermes/hermes-agent/tui_gateway/session_compression.py __annotate__rs));)5)c ^RIHpVPV4pVP4UUu/uF'wr4VP R4'g VR8XgK%W4bK) ppp\ V\ 4'd7\ VPR4\ 4'dVPR4M/pTPRUu/uFpRV 2VPV4bK up4\\VP444#uuppiuupi)zStable snapshot of compression/context keys that must apply next turn: the messaging-gateway cache-busting extract plus ``idle_compact_after_seconds``/``tail_mode`` (live-TUI-only keys).) GatewayRunnerz compression.zmodel.context_length compression)idle_compact_after_seconds tail_mode) gateway.runr_extract_cache_busting_configitems startswith isinstancedictgetupdater sorted)rrkeyskvpickedrs& r !_tui_compression_config_signaturer"s*  6 6s ;D#zz| k|tqq||N/K/KqTjOjdad|F k,6sD,A,AjQTQXQXYfQgimFnFn#''-(tvK MMCnoCna\!%{q'99Cnop  ' ((los"C?C?8Dc$V^8dQhRRRRRR/#)rnamestrfallbackAnyr r )r s"r rrs!3##rc^RIp^RIHpVPVP4P V,P pWBPPJdV#T# \dTu#i;i)uDefault read off ContextCompressor.__init__'s REAL signature, so unset-key restoration uses the construction path's derivation instead of a hardcoded copy that could drift. Unset restoration must go through the same derivation the construction path uses (#94724 review finding on #95980) — pulling the default off ``ContextCompressor.__init__`` itself instead of hardcoding copies keeps the two from drifting. N)ContextCompressor) inspectagent.context_compressorr) signature__init__ parametersdefault Parameterempty Exception)r$r&r*r)r/s&& r _compressor_ctor_defaultr3se>##$5$>$>?JJ4PXX"&7&7&=&==xJ7J sAAA A/.A/cb^RIHpVPR4;'g/PR4#)uThe cap a fresh agent build installs when the key is absent: DEFAULT_CONFIG's ``compression.threshold_tokens``. agent_init reads the MERGED config, so "no key in config.yaml" installs that default at construction; key removal here must restore the same value, or a live session would diverge from a rebuilt one after the first turn (#117093). An explicit ``threshold_tokens: null`` stays ratio-only — the key is present, so ``.get`` returns it untouched.DEFAULT_CONFIGrthreshold_tokens)hermes_cli.config_defaultsr6rr5s r _default_threshold_tokens_capr9*s,:   } - 3 3 8 89K LLrc$V^8dQhRRRRRR/#)ragentr'rrr floatr )r s"r rr6s!crc \\RR44p^RIHp^RIHpHpH p\VRR4;'gR\VRR4;'gRr\VPRR 44P4R 9p T!Y$!WxV R 7Yu!Wx4;'g V!Wx4R 7wr*V# \\3dRpLi;i \dT#i;i) uDefault compaction threshold when ``compression.threshold`` is unset. Mirrors agent_init: ctor global default, then per-model resolution (Codex autoraise etc.) via the SAME ``_resolve_compression_threshold`` — removing the key restores the model-derived value.threshold_percentg?)_resolve_compression_threshold) _compression_threshold_for_model_is_codex_gpt54_or_gpt55_is_codex_sparkmodelprovidercodex_gpt55_autoraiseT)allow_codex_gpt55_autoraise)rCis_codex_autoraise>1yestrue)r<r3 TypeError ValueErroragent.agent_initr?agent.auxiliary_clientr@rArBgetattrr%rlowerr2) r;rpctr?r@rArBrCrEautoraise_enabled_notices && r "_derived_default_threshold_percentrU6s,-@$GH  Cvv!%"5;;WUJXZ=[=a=a_ax 0G NOUUW[oo5 1%_pq,DU,U,y,yYhinYy  J z "   J s.B-#CCAC-CC CCc$V^8dQhRRRRRR/#)rr;r'rrr Noner )r s"r rrVs&U8U8#U8KU8DU8rc \ \V\4'dTM/p\VPR4\4'dVPR4M/p^RIHpHpVPRR4p\V\ 4'dTM\V4P4R9Vn \VPRR44Vn VPRR4p\V\ 4'g\V4;p^8:d\hWpn\$P&!\\4;_uu_4\)^\VPR ^4;'g^44VnR R R 4\-VR R 4pVfR #\\/R R44p \VPR V 4;'gT 4P14P4p V R9dT MT Vn\4Fwrp \\/W44pVPW4p\$P&!\\4;_uu_4\7Y\)YfTM \V444R R R 4K \$P&!\\4;_uu_4VPR\/RR44p\)R\9\;V4R44VnR R R 4VPR4p\V\4'doVP?4UUu/uFQwpp\V\\:34'gK$\V\ 4'dK<\V4\;V4bKS uppM/Tn ^RI!H"pR pRV9dC\$P&!\\4;_uu_4\;VR,4pR R R 4Vf \GW4pV;Vn$Vn%T!\-VRR4;'gRVP@T\-VRR4;'gR4;pVn&VPOVPPV4Vn)V!W4pVe=V!VV4\$P&!\T4;_uu_4VVn(R R R 4M\-VRR 4eV!VR 4R Vn+VPYVPR\[444Vn.R ;Vn/Vn0R # \\3d\P!R T4RpELi;i +'giEL;i +'giEK`;i +'giEL;iuuppi +'giEL;i \Td TTn)ELAi;i +'giL;i)uUpdate a live session's compressor in place from config.yaml. Every adopted key has UNSET semantics: a removed key restores the normalized default (or model-derived value) through the construction path's own derivation — acting only on PRESENT keys would leave stale values active forever. Every adopted key has UNSET semantics (#94724 review finding on the merged #95980): removing a key from config.yaml restores the normalized default — or the model-derived value — on the next turn, through the same derivation the construction path uses (ContextCompressor ctor defaults read off its real signature, the Codex threshold autoraise via ``_resolve_compression_threshold``, context-length re-inference via the deferred ``get_model_context_length`` resolution). r)!config_context_length_for_runtimeset_config_context_lengthenabledTcodex_responses_nativeF!codex_responses_compact_thresholdi@ zGInvalid compression.codex_responses_compact_threshold=%r; using 200000.rNcontext_compressorrlean target_ratiosummary_target_ratiog?g?g?model_thresholds)resolve_model_threshold thresholdrCrDrE_config_context_lengthr7>rIrJrK)legacyr_)1rrrrNrYrZboolr%rQcompression_enabledr!codex_responses_native_compactionintrMrLloggerwarningr] contextlibsuppressmax&compression_idle_compact_after_secondsrPr3stripr_COMPRESSION_INT_KEYSsetattrminr<rarrbr+rcrU_config_threshold_percent_configured_threshold_percent_base_threshold_percent_effective_threshold_percentcontext_lengthr>r2_resolved_context_length_coerce_threshold_tokens_capr9threshold_tokens_cap_threshold_tokens_tail_token_budget)r;rrrYrZ enabled_rawnative_threshold_rawnative_thresholdcc default_tailmodekeyr& min_valuer/raw ratio_rawraw_thresholdsrr rcrRbasenew_ctxs&& r _apply_live_compression_configrVsC&&#BC,6sww}7Mt,T,T#''-(Z\K]//)T2K/9+t/L/L RUVaRbRhRhRjoCSCE.=kooNfhm>n.oE+&??+NPWX# *D 1 1#NbJc6c6Fhi5i 6j /?+   Y 3 37:1c+//RnpqBrBwBwvw>x7y4 4 ,d 3B z/ VDEL {{L9II\ J P P R X X ZD#554ooc+  J 7 7 BS{GCQ R8 7%:   Y 3 3OON4LMcei4jk "%dCi0@$,G"H 4!__%78N ND ) )&4%9%9%;%;TQz!cSX\?ZcmnoqucvAa%;/1 ACk!  J 7 7 K01C8 {0DFIIB 2#C(?w#))r2+>+>WUT^`bEcEiEigi)D2 %#!>>r?P?PRVW 0;G "%1   + + 'B , + -t 4 @ "%.&*# ==*,I,KLB487B20A z "#`bvw"# 4 3 38 7 7 3 3 3 8 7 7 #"#, +ss.S;55T+%T?AU!U(U(U(6U.5!V V;)T('T(+ T< ? U  U% . U? VV V+ c$V^8dQhRRRRRR/#rsidr%sessionrr rWr )r s"r rrs&UUSU4UDUrc"VPR4pVfR#\4;'g/p\V4pVPR4pWAR&WE8XdR#\W#4R# \d"p\ P RY4Rp?R#Rp?ii;i)a,Adopt compression.* / model.context_length edits at turn start (messaging gateways rebuild the agent on these keys; Desktop/TUI keeps the live compressor, so it must be updated in place). Desktop/TUI only synced the model; the live compressor kept the threshold captured at agent creation (#95151). r;Nconfig_compression_seenz2Could not apply live compression config for %s: %s)r _load_cfgr"rr2rkrl)rrr;rr,seenes&& r #_sync_agent_compression_with_configrs KK E } +  C1#6I ;;0 1D)2 %&U&u2 UKSTTUs A"" B-B  Bc$V^8dQhRRRRRR/#rr )r s"r rrs!%%S%4%D%rcVPRR4pV'dVPR4fR#VPR4;'g VR,p\WVR,\VPR44R7pVPR4'gR#VPR 4;'gVPR 4;'gR p\P R W0VP R ^4^,4\VR,RR 4;'gRpRV RV R2p\RVRVP4RRRRRRRRRR/4\W4R# \d'p\P RY0T4RT 2pRp?L`Rp?ii;i) u!Apply a model switch queued (``session["pending_model_switch"]``) while a turn was running. Runs on the TURN thread at turn start — nothing in flight — so the in-place swap (client rebuild) is safe. A failed switch keeps the current model and never blocks the turn. A dropped pick is a warning notice, not an ``error``: clients paint ``error`` as a failed turn (Desktop's red retry card under the user's message) while this turn runs normally on the old model. The session.info re-sync moves the pill off the pick the session never adopted.pending_model_switchNr; display_modelrconfirm_expensive_model)rconfirm_requiredconfirm_messagerlrDz4Queued model switch to %s dropped for session %s: %s rCzthe current modelz Stayed on z: switching to z. needs confirmation. Pick it again to confirm.z3Queued model switch to %s failed for session %s: %szCould not switch model: znotification.showtextlevelwarnkindttlttl_msi.rzmodel_switch.droppedid) popr_apply_model_switchrgrkrlsplitrPr2_emitrstrip_emit_session_info) rrpendingrCresultdetailcurrentrrs && r _apply_pending_model_switchrskk0$7G gkk'*2 KK ( : :GENE.$S75>[_`g`k`kmFaG\HIzz,-- -.MM&**Y2GMM2Mu[a[g[ghlno[pqr[st''*GR8OO? !; ^ $ $ KK14 8!&GI % 's4^S: ! % $W^ $ $ KK14 8!&GI % $ $ $ 's4^S:seEAB:#E,C 0EC !E: C E C E D>2D D> D#  D>>Ec 0V^8dQhRRRRRRRRR RR R /#) rrr focus_topicr approx_tokensz int | Nonebefore_messagesz list | Nonehistory_versionr ztuple[int, dict]r )r s"r rrs>0-0- 0- *0-BL0- 0-:D0-0-rc aa^RIHp^RIHpHpHpHp SR,p VeSfRSR,;_uu_4\SPR.44\SPR^44upoRRR4\V4V8d^\V 43#T !T;'gR4p V P'd \V4h\SPR 4;'gR\S4R 7p VV3R lp T!YT SPR 4;'gR V R 7p\!V 4VP"R8Xd^\V 43#VP"R8Xd\%VP&4hVP"R8wd^\V 43#SR,;_uu_4\SPR^44S8wd"V!V RR7^\V 43uuRRR4#VP(SR&S^,SR&RRR4VP*\V 43# +'giEL;i \!T 4i;i +'giLK;i)aSingle choke point for all manual-compress routes. ``focus_topic`` is the RAW argument string after ``/compress``; the shared core (``agent.conversation_compression_manual``) parses boundary forms (``here [N]``, ``up to here``, ``--keep N``) so a partial compress triggers on EVERY route instead of a FULL compress focused on the literal text. ``--preview`` returns without touching history.)0finalize_context_engine_compression_notification)AGGRESSIVE_UNSUPPORTED MIN_MESSAGES compress_nowparse_compress_argsr;NrhistoryrrD session_key)cwdc<SR,;_uu_4\SPR^44S8HuuRRR4# +'giR#;i)rrN)rjr)rrsr snapshot_is_current6_compress_session_history..snapshot_is_currents6 ^ $ $w{{#4a89_L% $ $ $s < A r/)task_idrpreview lock_skipped compressedF) committed)agent.conversation_compressionr%agent.conversation_compression_manualrrrrlistrrjlen _get_usage aggressiverM_set_session_context _session_cwd_clear_session_contextstatusr lock_holderafter_messagesremoved)rrrrrrrrrrr;requesttokensrrsf&&&f r _compress_session_historyrs `QQ G E/"9 ^ $ $/3GKK 24N/OQTU\U`U`artuUvQw ,O_% ?l**U###!+"3"34G/00"'++m"<"B"B U\H] ^FM'egw{{S`GaGnGnen2EG v& }} !*U### }}&!&"4"455 }} $*U###  w{{,a0 1_ D >:e, ,,C% $ $$ v& ! s/8H:H- H-7H=H= H* - H:= I clear_pending_titleTrestart_slash_workerc ,V^8dQhRRRRRRRRRR /#) rrr%rrrrgrr rWr )r s"r rr9s4"0"0 "0"059"0X\"0 "0rc aVPR4p\VRR4;'gRpVPRR4;'gRpV'dWV8XdR#\SWR7'g\P RSWe4YQR&\ P !\4;_uu_4^RIH p\ P !\4;_uu_4VPV4RRR4^R I H pV!We4\ P !\4;_uu_4VPVV3R l4RRR4RRR4\VPR ^44^,VR &V'dRVR &V'd:\ P !\4;_uu_4\SV4RRR4R#R# +'giL;i +'giL;i +'giL;i +'giR#;i) aRe-anchor the gateway-side ``session_key`` when _compress_context rotates ``agent.session_id``; otherwise approval routing, slash worker, DB lookups and yolo state keep targeting the ended parent. ``clear_pending_title``: True for manual /compress (title belongs to the old session), False for post-turn auto-compression. ``restart_slash_worker``: False only when the caller manages the worker.r; session_idNrDr)new_session_idzWCompression session lease did not re-anchor: sid=%s old_session_id=%s new_session_id=%s)approval)transfer_session_yoloc<\SV4#r)_emit_approval_request)datars&r 2_sync_session_key_after_compress..SsJ`adfjJkr_queued_prompt_generation pending_title)rrP_transfer_active_session_slotrkrlrmrnr2toolsrunregister_gateway_notifytools.approval_yolorregister_gateway_notifyrj_restart_slash_worker) rrrrr;rold_keyrrs f&$$ r _sync_session_key_after_compressr9sj KK EUL$7==2Nkk-,22G ^6 (g U U e  ,M   Y ' '"   + +  . .w 7,=g6   + +  , ,^=k l, (,/w{{;VXY/Z+[^_+_G '(#'    + + !#w /, +, +, + ( ', + +sH&)GF5 !8GG 0G G.5 G G G G G+ . G? cV^8dQhRR/#)rr rWr )r s"r rr^s000rc2\\4VRR7R#)zQPublish this module's helpers + handlers onto ``server``, rebound to its globals.)skipN)_)rglobals)servers&r registerr^s 6/r))proactive_prune_tokensr) proactive_prune_min_result_charsi@r)"proactive_prune_min_reclaim_tokensir)protect_last_nr)min_tail_user_messagesr)NNNN)r __future__rrmutilsr method_ctxrr"r3r9rUrrrrrr2rrcontextmanagerrrrrr rr r"sN#!#)" M.U8pU,%BJ)Juiu ;;(0-f"0<@"0_c"0J0r