+ jHjRt^RIHt^RIt^RIHt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIHt^RIHt^RIHtHt^RIHt^RIHt^R IHt^R IHt^R IHt^R IH t H!t!H"t"H#t#^R I$H%t%^RI&H't'^RI(H)t)H*t*^RI+H,t,^RI-H.t.^RIH/t/H0t0H1t1H2t2H3t3H4t4^RI5H6t6]'d ^RI7H8t8^RI9H:t:]Pv!R4t<!RR4t=R#)z;Gateway turn hygiene phases; inherited by GatewayTurnMixin.) annotationsN) TYPE_CHECKING)t)format_iteration_progress) nullcontextsuppress) copy_context)Platform)(repair_explicit_computer_use_media_paths)BasePlatformAdapter) MessageEvent) SessionSource_session_key_namespacebuild_channel_continuity_notebuild_session_context)TranscriptReadError) TurnContext)DEFAULT_LEASE_WAITTurnLeaseTimeoutError)get_hermes_home_override)Path)AnyCallableDictListOptionalTuple)base_url_hostname) GatewayRunner) TurnRunnerz gateway.runc]tRt^*t]P !RR44t]R4tRt Rt Rt Rt Rt ]R 4tR tR tR tR tRtRtRtRtRtRtRt]R4tRtR#)GatewayTurnHygieneMixincD]tRt^+t$RtR]R&R]R&R]R&R]R&RtR #) $GatewayTurnHygieneMixin._HygienePlanz'Hygiene pre-check outcome for one turn.boolneeds_compressint approx_tokens msg_countwarn_token_thresholdN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__r*=/home/ubuntu/.hermes/hermes-agent/gateway/run_turn_hygiene.py _HygienePlanr#+s5!!r2r4c aVPR/4p\V\4'dW nM\V\4'dVPR4;'g&VPR4;'g VPVnVPR4pVe6\ \ \4;_uu_4\V4Vn RRR4VPR4;'gRVn VPR4;'gRVn VPR/4o\S\4'gR#\SPRR 44P4R9Vn RV3R llpV!R VP\4VnV!R VP\ 4VnV!R VP"\ 4Vn\%VP"VP4VnV!RVP&\ 4VnV!RVP(\ R R7VnR# +'giELn;i)zgApply model / compression knobs from the gateway config onto ``hs`` (invalid values keep the defaults).modeldefaultcontext_lengthNproviderbase_url compressionenabledTc<SPV4pVfV#V!V4pT'd T^8d T#T^8dT#T# \\3dTu#i;iN)get TypeError ValueError)keycurrentcast allow_zerorawparsed _comp_cfgs&&&& r3_knob@GatewayTurnHygieneMixin._hmwa_hygiene_read_config.._knobJsd--$C{ c.8fk6 UVaZ6 Ug Uz*  s>AAhygiene_hard_message_limithygiene_timeout_secondshygiene_total_ceiling_secondshygiene_max_turn_hold_seconds hygiene_failure_cooldown_seconds)rE>1yestrue)F)r? isinstancestrr6dictrr@rAr&config_context_lengthr9r:lowercompression_enabledhard_msg_limittimeout_secondsfloattotal_ceiling_secondsmaxmax_turn_hold_secondsfailure_cooldown_seconds)hsdata _model_cfg_raw_ctxrIrHs&& @r3_hmwa_hygiene_read_config1GatewayTurnHygieneMixin._hmwa_hygiene_read_config4sXXgr* j# & &!H  D ) )!~~i0WWJNN74KWWrxxBH!~~&67H#i44/28}B,5$..4<<BK$..4<<BKHH]B/ )T** !$Y]]9d%C!D!J!J!LPd!d V"">@Q@QSVW"#P>PRWX#()H"JbJbdi#j #&r'?'?ASAS#T #()H"JbJbdi#j &+ .0K0KU_c' #7544s ;H11 I c "^RIHpVPRRRRRRRR R R R R /R 7 pV!4VnVP'dVP WDP4VP VP VPrvp\\4;_uu_4TPY\VP\4'd VPMR R 7wVnpVPR 4;'g VP VnVPR4;'g VPVnVPR4;'g VPVnR R R 4VPeE^RIHp V !WTP WtPWdP 4GR jxL 'dR VnVPfVP'dz\\$\&4;_uu_4^RIHp Hp V !VP4p X !VP VPV R7p V 'd\1V 4VnR R R 4V#V# +'giL;iL \d R TnLi;i \d7TPPR4p \T \.4'g.p Li;i +'giT#;i \dT#i;i5i)aaResolve model/provider/context-length + hygiene knobs (fail-soft: errors keep defaults). The 0.85 threshold is deliberately HIGHER than the agent's compressor (0.50): a safety net for sessions that grew between turns. ``max_turn_hold_seconds`` bounds the TURN wait (compressor keeps running detached, commit fenced); kept below transport idle-timeouts.)_load_gateway_configzanthropic/claude-sonnet-4.6g333333?Tig>@g@g$@gr@N) r6 threshold_pctrXrYrZr\r^r_rVr9r:api_keyrasource session_key user_configr9r:ri)should_clear_context_pin_async)get_compatible_custom_providers"get_custom_provider_context_lengthcustom_providers)r6r:rq) gateway.runrg_HygieneSettingsrardr6r9r:r Exception_resolve_session_agent_runtimerSrUr?rirVhermes_cli.route_identityrnr@rAhermes_cli.configrorplistr&)selfrkrlrgr`configured_modelconfigured_providerconfigured_base_url _hyg_runtimern_gw_gcp_gw_gccl_hyg_custom_providers_hyg_custom_ctxs&&& r3_hmwa_hygiene_settings.GatewayTurnHygieneMixin._hmwa_hygiene_settings^sx 5  " "/tY]U"&^bD$R #  . *,BGwww..r77;IKSUS^S^`b`k`k3F )$$)-)L)L!+5bggt+D+D$*M*&,+..z:IIbkk *..z:IIbkk )--i8FFBJJ %''3 4X;(((4G+[[480 ''/BKKKi44 7180@- '/ hhOd'O'363G05$ r S%$ !4/3B,4%702 KKKK K KK-K K*&K-)K**K-c "^RIHpHpT!VPVP;'gRVP ;'gRVP VP;'gRR7GRjxL p\WqP,4p\VR,4p \V4p ^RI H p H p Rp V !V !VPVP44;_uu_4VP^8:d3^RIHp\#VRR4pV!\#VR V4VP$V4p VP^8dVPR ppMV eT R ppM V!V4R ppRRR4XV8;'gWP&8pV'd\#VRR4p\#\#VR V4R R4pVe~Rp\)\*4;_uu_4V!VP$4pRRR4V'dBVP-R^4^8d+\.P1RVP$VR,4RpV'dBVP3V4GRjxL 'd#\.P1RVP$4RpV'd<\.P1RV VR X\VP^d,4VR VR 4VP5VVW4#ELY +'giEL|;i +'giEL;iL5i)zDecide whether hygiene compression fires this turn (token/message thresholds, DB-backed failure cooldown, in-flight compression).)estimate_messages_tokens_roughget_model_context_length_async)r:rirVr9Ngffffff?)image_cost_contextlearned_image_token_cost)persisted_anchor_tokens _session_db_dbactualanchored estimated get_compression_failure_cooldownremaining_secondszXSession hygiene: skipping compression for %s; previous failure cooldown active for %.1fsFzVSession hygiene: skipping compression for %s; another compression is already in flightufSession hygiene: %s messages, ~%s tokens (%s) — auto-compressing (threshold: %s%% of %s = %s tokens),)agent.model_metadatarrr6r:rirVr9r&rhlenagent.image_token_costrrlast_prompt_tokensagent.usage_anchorrgetattr session_idrYrrtr?loggerinfo"_session_has_compression_in_flightr4)ryr`history session_entryrlrr_hyg_context_length_compress_token_threshold_warn_token_threshold _msg_countrr _anchoredrr_approx_tokens _token_source_needs_compress_getter_cooldown_states&&&&& r3_hmwa_hygiene_plan*GatewayTurnHygieneMixin._hmwa_hygiene_plans h$B HHr{{00b"**:J:J"$":":R[[EVEVTV%  %((;>N>N(N$O! #$7$$> ?\ X  82;; O P P//14F%dM4@ 3K V>VX_ //!30=0P0PRZ  &09:  0Nw0WYd Q ),EEhhWhWhIh  "$ t= %.1fs) — abandoning inline wait, proceeding without compression this turnzturn-hold budget z.1fzs elapsed after s)idlerwaitedceilingfence_cancelledg& .>uSession hygiene compression for session %s still streaming after %.0fs (last progress %.1fs ago) — extending wait (ceiling %.0fs))'agent.conversation_compression_deadlinerrrrr commit_fence is_cancelled TimeoutErrortime monotonic wait_startedr\minr]rZseconds_since_progressr^asynciowait_forshieldfuturerrr)ryattemptr`rrrrfence _hyg_waited_ceiling_slice_turn_hold_remaining _idle_left _compressed__idles&&&& r3_hmwa_hygiene_wait_for_summary6GatewayTurnHygieneMixin._hmwa_hygiene_wait_for_summarysP NS$$!!!""..*W-A-AAK(0H0H'J^J^_HR//%2N2N2PPRWXX3U;=F$&#;#;t~~?ORYRfRf?f#g 2a7USMachIi=jFR//%2N2N2PPRWXJ&F! '.'7'7w~~8V`f'g!g """h %%%"nn.1E1EE ,U4L4LgNbNbc446":"::KK8&00+?W?W  2+B,D,DS+IJ))4S(9<.(:(:;$6H6Hd!22 a)44k( = sH-J5DJ5 9FFF J5FJ2.C>J2,J50J22J5c >"VPpVP'gaVP4pVf!\P!R4GRjxL KFV'd$VP 4VP W4R#VPGRjxL wrVV#LJL 5i)uCancel the worker at the commit fence; on success release its lease and defer agent cleanup, returning ``None``. When the worker already crossed into its commit, consume and return the compressed transcript instead (a successful compaction is never a timeout; the turn may be held past the budget by up to the commit duration — by design). The lock-free ``commit_in_flight`` marker keeps the poll from spinning on a hung commit.Ng?)rcommit_in_flighttry_cancel_before_commitrsleep"release_cancelled_compression_lock_hmwa_hygiene_defer_cleanupr)ryrcontextr cancelledrrs&&& r3_hmwa_hygiene_cancel_or_adopt5GatewayTurnHygieneMixin._hmwa_hygiene_cancel_or_adopt s $$(((668I mmE***88:00B&~~- +.s.B-BB B3BB BBc dVPVPVPVR7RVnR#)zQHand the agent's cleanup to the still-running worker future and mark it deferred.rTN)&_defer_agent_cleanup_until_future_doneragentcleanup_deferred)ryrrs&&&r3r3GatewayTurnHygieneMixin._hmwa_hygiene_defer_cleanup4s( 33GNNGMM[b3c#' r2c D^RIHp^RIHpV!W\ WB4V4R#))ActivityProvenance)%_stamp_hygiene_compression_provenanceN)agent.session_activityrrrrr)rdescprovenance_name debug_labelrrs&&&& r3_hmwa_hygiene_stamp+GatewayTurnHygieneMixin._hmwa_hygiene_stamp9s=E-e7CU;gitur2c 0"VPV4pV'dGVP'd3VPVPW2VPR7GRjxL R#R#R#L \d"p\ P RYF4Rp?R#Rp?ii;i5i)zOBest-effort user notice on the hygiene thread; failure is logged, never raised.)metadatalogical_platformNz Failed to deliver %s to user: %s)_delivery_adapter_forchat_id emit_warningplatformrtrwarning)ryrkmetamessagewhat_adapter_werrs&&&&& r3_hmwa_hygiene_notify,GatewayTurnHygieneMixin._hmwa_hygiene_notify?s L11&9HFNNN++FNNG=C__,NNN+xN L NN=t K K LsEB*A'+A'A%A'B%A'' B2BBBBc "^RIHpHpVP^8dR#\P !WPW!P4GRjxL pV!WWt4R#L5i)zNEscalate the failure streak (off-loop) and persist the cooldown, when enabled._hygiene_cooldown_for_failure_record_hygiene_cooldownN)rrrrr_r to_thread)ryr`rlrreasonrr _hyg_cooldowns&&&&& r3%_hmwa_hygiene_record_failure_cooldown=GatewayTurnHygieneMixin._hmwa_hygiene_record_failure_cooldownIsJW & & * %// )>Y>Y   !=I sAAAAc aaa"^RIHoHoHoVPp\ \ VRR44;'dVP'*pV'dUVPVR4VPYAPrpWW3VVV3Rllp VPPV 4Rp M6VPVR4GRjxL p V eV #S!WPSR4R p VPVPR R R 4\P!R VP\"P$!4VP&, V 4VP)WQP*\-R4R4GRjxL hLL5i)u``except HygieneTurnHoldExceeded`` body: keep or cancel the worker's commit admission, notify the user, and re-raise; returns the compressed transcript only when the worker was already committing. Turn-hold expiry is an availability boundary, not a failure: the streak must NOT advance, only flat retry spacing is recorded. A watermark-fenced commit (rows appended after compression start survive as cloned tail) KEEPS admission: the turn proceeds uncompressed now and the summary is adopted at the worker's fenced commit — always cancelling burned every attempt for thinking summary models. Without the fence a late commit could clobber newer turns, so cancel.)_HYGIENE_TURNHOLD_RETRY_SECONDSr_reset_hygiene_failure_streakcommit_watermark_fencedFzsession hygiene turn-holdc<VP4pVRJ;'d/\\VRR44;'g\VRV4V8gpV'd"\ PRV4S !W4R#S !WSR4R# \P\ 3dRpLTi;i \ d"p\ PRT4Rp?R#Rp?ii;i)N_last_compaction_in_placeFruSession hygiene compression for session %s finished after the turn-hold was released — summary adopted at the watermark-fenced commit boundary (#97963)z7hygiene streak reset after deferred adoption failed: %sz^hygiene compression deferred: turn-hold budget expired and the detached attempt did not commit) exceptionr$rrCancelledErrorrtrrdebug) _fut_gw_sid_skey_agent_exc _committed_rs_errrrrs &&&&& r3_hyg_adopt_or_space_retryUGatewayTurnHygieneMixin._hmwa_hygiene_on_turn_hold.._hyg_adopt_or_space_retryjs>>+D"&""WV-H%PQGG"6<>$FKK348 i5cA -#B:) .. :'!&J'%i %^`ghhis)B,B%B"!B"% C0C  Cul — the watermark-fenced worker keeps its commit admission and the summary will be adopted when it finishesNz\hygiene compression deferred: turn-hold budget expired while the summary was still streamingrz%session hygiene compression turn-holdAGENT_COMPRESSION_TURNHOLDz3hygiene compression turn-hold activity stamp failedzxSession hygiene compression for session %s exceeded turn-hold budget (%.1fs); proceeding without compression this turn%sz"gateway.compress.turnhold_deferredzcompression-turnhold notice)rrrrrrr$rrrrrradd_done_callbackrrrrrrrrrr)ryrr`rrlrkr_hyg_keep_admissionr r r r _log_suffix_adoptedrrrs&&&&&& @@@r3_hmwa_hygiene_on_turn_hold2GatewayTurnHygieneMixin._hmwa_hygiene_on_turn_holdSsj  $$"752KU#SToo]b]o]oYo   , ,W6Q R#0":":KD485  : NN , ,-F G3  "??IdeeH# $..0O.  K   MMB (*_    9  $ $dnn&69M9M&M{ '' LL!$H"IKh    -f& s,A E4A)E4<E0=B-E4*E2+E42E4c "^RIHpVPpVPpV'dVP 4VP p VP VR4GRjxL p V eV #TPY$VPRV 'dRM V'dRMR,4GRjxL TPVPV 'dRMR R R 4V 'd"\PR VP4h\P!4VP, p V'd-\PR VPWP 4M:\PRVPVP#4WP$4VP'WQP(V!WVP*VP R7R4GRjxL hELsEL0L 5i)z``except asyncio.TimeoutError`` body: cancel at the commit fence, record the failure cooldown, warn the user, and re-raise; returns the compressed transcript only when the worker crossed the commit boundary first.)$_hygiene_compression_timeout_messagezsession hygiene timeoutNzsession hygiene compression zcancelled at commit fenceztotal ceiling exhaustedz/timed out with no output from the summary model5session hygiene compression cancelled at commit fencez%session hygiene compression timed outAGENT_COMPRESSION_TIMEOUTz1hygiene compression timeout activity stamp failedzlSession hygiene compression for session %s was cancelled at the commit fence; continuing without compressionzSession hygiene compression for session %s reached its total ceiling after %.1fs (progress observed=%s); continuing without compressionzSession hygiene compression for session %s made no progress for %.1fs (total wait %.1fs, ceiling %.1fs); continuing without compression)total_exhaustedelapsed idle_timeoutprogress_observedzcompression-timeout warning)rrrrdeadline_exceeded)retain_compression_lock_until_worker_donerrrrrrrrrrrr!rr\rrrZ) ryrr`rrlrkrr_hyg_total_exhausted_hyg_fence_cancelledr _hyg_elapseds &&&&&& r3_hmwa_hygiene_on_timeout0GatewayTurnHygieneMixin._hmwa_hygiene_on_timeouts E$$$66   ; ; =$11;;GE^__  O88 ]55 */C+2F.F       MMG[ C8 ')\  NN?@M@X@X  ~~''*>*>>  NNO((,8O8O  NNT((%*F*F*H,XpXp  '' LL 0 4//5CZCZ  *     Y` B sPAGG 3GG G!!GGAG$B#GGGGGc  b^RIHpHpVPP 4VP 'gVP VR4VP^8d)V!WPV!WVP4R4R#R# \d"p\PRT4Rp?R#Rp?ii;i)u ``except BaseException`` body (caller re-raises): revoke commit admission BEFORE the host unwinds so the detached worker can never commit later, and record a cooldown — otherwise the next turn re-arms hygiene and waits up to 600s behind a fence that refuses again.rzsession hygiene unwindrz)hygiene unwind cooldown record failed: %sN) rrrrrrevoke_commit_admissionrrr_rrtrr)ryrr`rrlrr_cd_errs&&&&& r3_hmwa_hygiene_on_unwind/GatewayTurnHygieneMixin._hmwa_hygiene_on_unwinds X446'''  , ,W6N O & &! + S(221$RE`E`aK , S H'RR Ss%B B. B))B.c h"^RIHp ^RIHp VPp V P p WP 8gp \ \V RR44pV !V4pV !V4pV 'd2VV8d+\PRVP VR VR 4Rp TpV 'dVPPVP W4GRjxL 'g'\PRVP V 4Rp RpMeWnVPWxV 4VPP4GRjxL \P !VP"WeR R 7GRjxL V 'g V'd"^VnW!n\)V4pV !V4pM?VP*pVP,p\PR VP V !V 44\P/R VP*VVP,R VR 4VVP08d\PR VR 4WVV3#ELeELL5i)aAdopt a finished compression (rotation / in-place / refused); publishes the transcript to continue with on ``attempt.history``. Returns ``(rotated, in_place, new_count, new_tokens)``. Rewrite only on rotation (NEW session id): in-place compaction already soft-archived the old rows and rewrite_transcript() would DELETE them; neither rotation nor in-place signals FAILURE and an unconditional rewrite would leave only the summary. Write-before-repoint: a repoint-then-failed-rewrite would point the live entry at an empty session.)hygiene_no_commit_reason)rrFzGateway hygiene compression for session %s would grow transcript (~%s -> ~%s tokens); keeping the original transcript unchangedrNuSession hygiene: failed to persist compressed transcript for rotated session %s → %s; keeping the live entry on the original session so the conversation is not droppedzhygiene-compression)ruGateway hygiene compression for session %s did not rotate or compact in place (%s) — preserving the original transcript instead of overwriting it with the summary (#21301).u>Session hygiene: compressed %s → %s msgs, ~%s → ~%s tokensz3Session hygiene: still ~%s tokens after compression)gateway.run_turnr/rrrrr$rrrasync_session_store!persist_rotated_compression_childerror_rebind_turn_lease_saverr_sync_telegram_topic_bindingrrrr(r'rr))ryrrrplanrrk _quick_keyrun_generationr/r _hyg_agent _hyg_new_sid _hyg_rotated _hyg_in_place _hyg_in_toks _hyg_out_toks _new_count _new_tokenss&&&&&$$$$ r3_hmwa_hygiene_adopt_transcript6GatewayTurnHygieneMixin._hmwa_hygiene_adopt_transcripts >G]] !,, #'?'?? WZ1LeTU 5g> 6{C ML8 NNE((\!,<-PQAR  !L!K 11SS!,,lIII 23@3K3K\ % % +7('' LQ..44666''55vUj =/0M ,)O[)J8EKJ,,K NNj((*B:*N   L NNJ4+=+=a*@kRS_  $33 3 NNPU`abTc eJ CCSI7sPBH2)H2H* H2AH2+H-,*H2H0 H2#H2+CH2-H20H2c "^RIHp Hp VPWWEWhWR7GRjxL wrpp\ VP RR4pVRJ;'d\ VRR4p\ VPP;'dV '*;'dV'*4pV'dRpV'gGV !VWVPWPVR7'd \P!WV4GRjxL V'dTPY'VPV'dR M \ VR R44GRjxL VPVP R R R 4V'gu^RIHpT!\ VR R4;'g \%R4RR7p\&P)RV4VP+WP,\%R4R4GRjxL R#R#Vev\ VRR4'da\ VRR4p\ VRR4;'g \%R4pVP+WP,\%RVVR7R4GRjxL R#R#R#EL'ELaEL"LL5i)zzAdopt a finished hygiene compression, rebind the session + turn lease, record streak/cooldown, and warn the user on abort.)rhygiene_compaction_recovered)rrkr8r9Ncontext_compressor_last_compress_abortedFT)abortedrotatedin_placer( new_countr' new_tokensr_last_summary_errorz#session hygiene compression abortedAGENT_COMPRESSION_COOLDOWNz/hygiene compression abort activity stamp failed)redact_sensitive_textzgateway.shared.unknown_error)forcez'Session hygiene compression aborted: %szgateway.compress.hygiene_failedzcompression-failure warning_last_aux_model_failure_modelr_last_aux_model_failure_errorzgateway.compress.aux_failed)r6r3zaux-model-fallback notice)rrrrErBrrr$rrr(r'rrrrr agent.redactrOrrrrr)ryrr`rrr7rrlrkr8r9rrEr<r=r@rA_comp _hyg_abortedr%rO_err _aux_model_aux_errs&&&&&&$$$$$ r3_hmwa_hygiene_apply_result2GatewayTurnHygieneMixin._hmwa_hygiene_apply_resultIsG \EIEhEh '}!FiF @ < Z  ';TBD(\\WU,E#8$?dd1EcCdlprH$O//LL!,M*NPm ( 752QSW#X#X (GLJu&EtLqqPQRpPqH++ a(EZ_g&h+  $Y U@ * V  s!II )I/I>I I! I+AI,I - I95I.I/)II5AII?I8I?I I IIIIc "^RIHpRp\VP\4'dVPP R4MRp \V \4'd&\ V P RR4;'gR4pV!WVPWVPVPVPR7GRjxL p \PRWPWPR 4R#L35i) a*codex app-server runtime: the real context is the server-side thread, not the transcript mirror. The detached-agent path would only rewrite the mirror and its finally-eviction would destroy the live thread (next turn starts blank), so use the cached agent's thread/compact/start and KEEP it cached.)run_codex_hygiene_compactionnativer;Ncodex_app_server_auto) auto_moderr'rZr_zHSession hygiene (codex app-server): %s (session=%s, mode=%s, ~%s tokens)r) rrr\rSrarUr?rTrr'r\r_rr) ryr`r7rrrlr}r\_hyg_codex_auto _hyg_comp_cfg_hyg_codex_outcomes &&&&&&& r3_hmwa_hygiene_codex_compaction6GatewayTurnHygieneMixin._hmwa_hygiene_codex_compactions =#6@$6O6O M2UY mT * *!-"3"34KX"V"b"bZbcO#? }77?,,b>V>V%'%@%@$    V  8 8/N`N`abMc  sA9C2 >?T U_d$    ", => KO 44 HPz %// =L $JA8**7 \ #  NN()6)A)A3QU    sJD%(C(C&C(r*)akws*,r3HGatewayTurnHygieneMixin._hmwa_hygiene_detached_attempt..sDr2)r\c n<SPSRSPSSP;'gRRR7#)rr7gateway_hygiene)r'rtask_idtrigger)_compress_contextr'r)r:_hyg_commit_fence _hyg_msgsr7rsr3rrs9 44r1C1CRc)44AA K\5r2)rrlrkr8r9zsession hygiener)"rrragent.conversation_compressionrr}rcompression_in_placercallabler_end_session_on_close _print_fnrget_running_loopr\rrun_in_executorrrunr_track_deferred_agent_workerrrrrrrr' BaseExceptionr,rY_evict_cached_agentr!_cleanup_agent_resources_off_loop)ryrr`r7rrrvr}rkrrlr8r9rrry_bind_hyg_statelooprr:rs&&&f&f&&&f&&& @@r3_hmwa_hygiene_detached_attempt6GatewayTurnHygieneMixin._hmwa_hygiene_detached_attemptsJ 8I,0,J,J:er,s&s# O" 6 d/3J +%gj:NPT&UWkmqrO((1I1IJ/4J ,#8J ++-D 6RMeMe f $5G !11 "" GN"  - -gnnj I#'>>#3G  $($G$GUb$cc 11['4}':-2    $ $[ 1+++<tooluser assistant)rrrrrrX_bound_hygiene_payloadrr%_HygieneAttempt_event_thread_metadatarurSrarUrTr?rWrcrrtrrr)ryeventrkrrlrr8r9rr`r7rrvr}mres&&&&&&&& r3_hmwa_run_session_hygiene1GatewayTurnHygieneMixin._hmwa_run_session_hygienes 8#g,*N..vC C%%%..wMJ J,,R-UU"""..wMJ J&&T8S8STY8bls&t J'+'J'J'1"''4'@'@BGGd(K( $J<##J/5526<<>BTT99"G\gvvv!!),,)0b155=Da3aQQ by>Q&==TI<{ ??g %..wMJ JODVwc'   J NNEq I I Js5H7G2H7'H75G56H7 5H7AH 0HG8HH7H-H1G: G:,H?G?H/H75H78H:HH4H7 H4H4H/*H7/H44H7c ^RIHpV!WP4pW@Jd@\P RVP \ V4\ V4VP4V#)u``bound_model_input_without_hygiene`` over ``hs.hard_msg_limit``, with one INFO line when the cut is real. Below the limit this is the identity — no allocation, no behaviour change.)!bound_model_input_without_hygieneuSession hygiene did not land for %s: bounding the model payload to %s of %s messages (hard limit %s) — the stored transcript is unchanged)r0rrYrrrr)rr`rrboundeds&&& r3r.GatewayTurnHygieneMixin._bound_hygiene_payload0sT G3G=N=NO  ! KKR((#g,G bFWFW  r2r*N)r+r,r-r. dataclasses dataclassr4 staticmethodrdrrrrrrrrrr'r,rBrYrcr}rrrr1r*r2r3r!r!*s"""' ' R<|HeT8t(( vv LJPd9vS$UDn7r ,!+F@dD1f  r2r!)>r/ __future__rloggingtypingrrrinspectjsonosqueue threadingr agent.i18nrrr contextlibrr contextvarsrgateway.configr gateway.media_repairr gateway.platforms.baser gateway.platforms.eventr gateway.sessionr rrrgateway.session_transcriptrgateway.turn_contextrgateway.turn_leaserrhermes_constantsrpathlibrrrrrrrrurrrrgateway.run_turn_runnerr getLoggerrr!r*r2r3rsA"   <,$#I60;,H5==#)2   = )R R r2