+ jHjRt^RIHt^RIt^RIHt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI t ^RIHt^RIHtHtHtHt^RIHt^RIHtHt^RIHt^R IHt^R IHt^R I H!t!^R I"H#t#^R I$H%t%H&t&H't'H(t(^RI)H*t*^RI+H,t,^RI-H.t.^RI/H0t0H1t1^RI2H3t3^RI4H5t5^RIH6t6H7t7H8t8H9t9H:t:H;t;^RIH?t?^RI@HAtA]P!R4tCRRltD!RR4tER#)z?Gateway turn persistence phases; inherited by GatewayTurnMixin.) annotationsN) TYPE_CHECKING)t)FAILED_TURN_DISPLAY_KINDFAILED_TURN_NOTICEOPEN_TURN_TAIL_ROLESPARTIAL_FAILED_TURN_NOTICE)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)diagnostic_wake_muted)DEFAULT_LEASE_WAITTurnLeaseTimeoutError)get_hermes_home_override)Path)AnyCallableDictListOptionalTuple)base_url_hostname) GatewayRunner) TurnRunnerz gateway.runcV^8dQhRR/#)returnbool)formats"A/home/ubuntu/.hermes/hermes-agent/gateway/run_turn_persistence.py __annotate__r,.s4cd^RIHp^RIHp\ V!W4RR4R8H# TdR#i;i)z\An editor session: ACP shows no reasoning event yet, so its reply keeps the projected block.) local_policy)RuntimeStoreErrorsourceNacpF) gateway.session_setting_commandsr/hermes_state_runtimer0getattr)runnerr1r/r0s&& r+ _acp_launchr7.s8=6|F3XtDMM s $//c]tRt^8tRRRlltRR RR!/tRtRtRtR t R t R t R t R t RtRt]R4tRt]RRl4tRtRtRRRRRR/tRtRtRtR#)"GatewayTurnPersistenceMixinNc V^8dQhRRRR/#)r&persist_user_display_kindz Optional[str]reply_expectedzOptional[bool]r))r*s"r+r,(GatewayTurnPersistenceMixin.__annotate__9s$Z>Z>$1Z>' Z>r-c "^RIHp HpHpHpVP R4;'gRpV !V4'dRpTP VV4p^RIHpH p^RI H pVP RV 4pVP RV 4pV'dDV!VV4'g5\PRYP;'gR 4R pV!4pM@V'd9V!V4'g+\PR YP;'gR 4VR 8XdqV'gi^R IHp\%VP R4;'gR4P'4;'g \)R4p\)RVP+VR7R7pVP R.4p\P-RYP;'gR T;'gR \.P.!4V , VP R^4\1V44V'dLV!V4'd>VP3V4GRjxL VP4P7V4GRjxL V'g(V!VV\1V4R7pV!VP:V4pVP R4'dVR,VP<8wdVP<V8XdVR,VnVP?WgVP<4VP4PA4GRjxL VP4PCVP<WR4GRjxL \DPF!VPHW$RR7GRjxL M+\P-RT;'gRWP<4VVV3#ELnELM \8d%p\PRTTRR7Rp?ELuRp?ii;iLLLq5i) aTurn the raw agent result into the outbound text: sentinel/silence handling, response logging, resume-pending clear, empty-response normalization, and identity-guarded post-compression session_id propagation. Returns ``(response, _intentional_silence, agent_messages)``.),_is_gateway_hidden_reasoning_incomplete_turn_normalize_empty_agent_response _sanitize_gateway_final_response'_should_clear_resume_pending_after_turnfinal_response)is_machinery_display_kindsilence_allowed)_unexpected_silence_replyqueued_terminal_display_kindqueued_terminal_reply_expectedz;silence marker rejected on a user turn: platform=%s chat=%sunknownFzEsilence marker suppressed on an unaddressed turn: platform=%s chat=%sz(empty))EMPTY_RESPONSE_EXPLANATIONmodelz)gateway.errors.empty_response_model_labelzgateway.shared.warn_passthrough)rL)errormessageszXresponse ready: platform=%s chat=%s session=%s time=%.1fs api_calls=%d response=%d chars api_callsNz&clear_resume_pending failed for %s: %sTexc_info) history_len session_idzagent-result-compressionreasonz{Skipping agent-result session split sync for %s because the session binding moved from %s to %s before compression finished?)% gateway.runr?r@rArBget_is_intentional_silencegateway.response_filtersrErFgateway.run_turnrGloggerwarningchat_iddebugagent.turn_explainersrKstrstriprr*infotimelen_clear_restart_failure_countasync_session_storeclear_resume_pending ExceptionplatformrS_rebind_turn_lease_save_record_gateway_session_peerasyncio to_thread_sync_telegram_topic_binding)self agent_resultr1history session_entry session_key _quick_keyrun_generation_run_start_session_id_platform_name_msg_start_timer;r<r?r@rArBresponse_intentional_silencerErFrG _silence_kind_silence_reply_expectedrK_modelagent_messages_es&&&&&&&&&&&&& r+_hmwa_shape_agent_response6GatewayTurnPersistenceMixin._hmwa_shape_agent_response9sU   ##$45;; 8 E EH#;;L(S X>$(()GIbc "."2"23SUc"d  G^(_(_ NNM ; ;) $) 02H !*CM*R*R LLW ; ;)  y )= H))'288b9??AssQGrEsF:B\BcBcjpBcBqrH%))*b9 f NN77i9Q9Q IIK/ )<+;+;K+KSQY]  B<PP33K@ @ @ g..CCKPPP $6|X[^_f[ghH7RH   L ) )l<.HMLdLd.d''+@@+7 +E ('' MD\D\]..44666..KK!,,k''55vUo F&&3(=?W?W -~==A AP g E{TVae ff g 7s5OA OO"O8O O"OO"O;OAO5 OAOO'N(O-N N NO=OA0OO -O4O5*OO O>ON O &O?OO  OOOsubtext blockquotec  naaVP\P8Xd\W4'gV#^RIHpHpHpV!V!4V!VP4R\\VRR44VP\P0R7pVPR4p V'dV'dV'g V 'gV#^RI Hp V P4P!4p \#V 4^8d<RP%V R ,4\'R \#V 4^, R 7,p MV P4p ^R IHp V !V!4V!VP4R R4pVP,PV4pV'dDVwpooRP%VV3RlV P!444p\'V4 RV RV 2#V !V 4p \'RWR7# \d3TP\P8XdRM \TRR4pELi;i \dRpLi;i)zPrepend the last reasoning block when show_reasoning is on for this platform. Mattermost requires an explicit per-platform opt-in (scratch text, not final-answer content).)_load_gateway_config_platform_config_key_resolve_gateway_display_boolshow_reasoning_show_reasoningF)defaultrjrequire_platform_override_forlast_reasoning)escape_code_fences_for_display :NNzgateway.reasoning.more_lines)count)resolve_display_settingreasoning_stylecodec3B<"TFq'dS V 2MSxK R#5iNr)).0lnemptyprefixs& r+ FGatewayTurnPersistenceMixin._hmwa_prepend_reasoning..s"jKiR26(2$5 @Kis zgateway.reasoning.block) reasoningr{)rjr LOCALr7rWrrrr(r5 MATTERMOSTrirXgateway.stream_consumer_fencesrrb splitlinesrejoinrgateway.display_configr_REASONING_QUOTE_STYLES)rqrrr{r1r|rrr_show_reasoning_effectiverrlinesdisplay_reasoningr_reasoning_style_quote header_key_quotedrrs&&&&& @@r+_hmwa_prepend_reasoning3GatewayTurnPersistenceMixin._hmwa_prepend_reasonings ??hnn ,[5N5NOii (E$&( >:;LM*6G[[; H,?,??WTSdfkEl & ( &%  &s%AG$&H$$9H! H!$ H43H4c  ^RIHpHpHp^RIHpV!4RJdR#^RIHpT!V!4V!VP4VPR4VPR^4;'g^VPR4;'gR V!R4VVPR 4VPR 4R 7 # \d"p \PR T 4R p ? R#R p ? ii;i)zRuntime-metadata footer for the FINAL message of the turn; off by default (display.runtime_footer.enabled=false). Never on a finite (`-z`, `chat -q`) turn: its reply is the printed answer itself.)rr_terminal_scope_cwd)finite_turn_requiredTrD)build_footer_linerLlast_prompt_tokenscontext_lengthNrequested_model served_model) user_config platform_keyrLcontext_tokensrcwd turn_secondsrrzruntime_footer build failed: %s) rWrrrgateway.session_finitergateway.runtime_footerrrjrXrir\r_) rqrrr1 _turn_secondsrrrr_bfl _footer_errs &&&& r+_hmwa_runtime_footer_line5GatewayTurnPersistenceMixin._hmwa_runtime_footer_lines `_?  !T )  H021&//B,JZJZ[bJc+//0DaHMMA+//0@AIIT'+- , 0 01B C)--n=   LL:K H s$AB1'B1/B11 C<CCc "VPPR/VCRT;'gRR,RVPRR4RVPRR4/C4GRjxL ^RIHpVP p.Vn\ V4FXwrg\P!VPV44V^d,^c8XgK:\P!^4GRjxL KZ ^RIHp VPV P4GRjxL R#LL6 \d!p\PR T4Rp?LVRp?ii;iL8 \d"p\P!R T4Rp?R#Rp?ii;i5i) zIagent:end hook, process-watcher scheduling, and watch-notification drain.z agent:endr{rD:NiNrLproviderN)process_registryzProcess watcher setup error: %szWatch queue drain error: %s)hooksemitrXtools.process_registryrpending_watchers enumeratern create_task_run_process_watchersleeprir\rM_drain_watch_notificationscompletion_queuer_) rqhook_ctxrrr{rwatchersiwatchere_prs &&&& r+_hmwa_post_turn_hooks1GatewayTurnPersistenceMixin._hmwa_post_turn_hookss@jjook, , "X^^T$:G\EUEUV]_aEb  ((R8,    ? ?'88H02  -'1 ##D$=$=g$FGs7b=!--***2 ; F11#2F2FG G G- + ? LL:A > > ? H ; LL6 : : ;sAE2DE2#ADDDD$$EE E E2D D>D94E29D>>E2E E/E*$E2*E//E2c j\T;'gR4P4pV'dV RV 2#T#)zTMake failed-turn delivery explicit without replacing the provider-specific guidance.rDr)rarb)rqr{notices&&&r+_hmwa_add_failed_turn_notice8GatewayTurnPersistenceMixin._hmwa_add_failed_turn_notices3x~~2&,,.,4(4x(@&@r-c ^RIHpT!VPR.4;'g.VPR^44p\;QJdRV4F 'gK RM RM !RV44'd\#\ #)zUChoose retry guidance without assuming completed tool effects can be repeated safely.)_current_turn_messagesrNhistory_offsetc3"TFNpVPR4R8H;'g.VPR4R8H;'dVPR4xKP R#5i)roletool assistant tool_callsN)rX)rmessages& r+rGGatewayTurnPersistenceMixin._hmwa_failed_turn_notice.. s[ ) KK 6 ) R R F#{2PPw{{<7P R(sAAATF)gateway.media_repairrrXanyrr)rqrrr turn_messagess&& r+_hmwa_failed_turn_notice4GatewayTurnPersistenceMixin._hmwa_failed_turn_notices}?/   Z , 2 2L4D4DEUWX4Y  3 ) 333 )   . -!!r-c "VPPV4GRjxL \9dR#VPPVRRRVR\P!4R\ /4GRjxL R#LTL5i)aAppend the gateway-owned assistant boundary iff the durable tail is open (a user row, or the tool row of a call that ran before the failure). The tail, not "did the gateway write the user row", is the key: on the primary path the agent's turn-start flush already persisted the row (so the platform-id dedupe skips the gateway write), and a platform redelivery of an already-closed turn must not stack a second assistant row.Nrrcontent timestamp display_kind)rgtranscript_tail_rolerappend_to_transcriptrdr)rqrSrs&&&r+_hmwa_close_failed_turn3GatewayTurnPersistenceMixin._hmwa_close_failed_turnsp))>>zJ JRf f &&;;J KFKn^vI     K s"A:A6A A:/A80A:8A:c ^RIHp\VPR44pV!V4p^RIHpV!V\ V44pV'd"\PRVP4MbV'd"\PRVP4M9V'd2\PRVPVPRR44WVV3#) a.Classify a finished turn for transcript persistence. Returns ``(agent_failed_early, hidden_reasoning_incomplete, is_context_overflow_failure)``. Context-overflow failures must NOT persist the user message (session would grow and reproduce the failure forever); transient failures (429/timeout/5xx) DO.)r?failed)"is_context_overflow_failure_resultzjSkipping transcript persistence for context-overflow failure in session %s to prevent session growth loop.upTransient agent failure in session %s — persisting user message so conversation context is preserved on retry.zLSuppressing hidden-reasoning-only incomplete gateway turn for session %s: %srMzprocessing incomplete) rWr?r(rXr[rrer\rcrSr]) rqrrrsrtr?agent_failed_earlyhidden_reasoning_incompleteris_context_overflow_failures &&&& r+_hmwa_classify_turn_failure7GatewayTurnPersistenceMixin._hmwa_classify_turn_failure!s M","2"28"<=&RS_&`#G&HWZ[bWc&d# & KKHIVIaIa  KKIJWJbJb ) NN^((,*:*:7D[*\ "@[[[r-c N"VPR4'd.\PRV'd VPMR4W#3#VPR4'dN\ VRR4\ P 8Xd.\PRV'd VPMR4W#3#VPR4'd_V'dWV'dOVPW4V4'gVPW4V4GRjxL pT;'gR\R 4,pW#3#L#5i) uAuto-reset a permanently oversized session so the next message starts fresh instead of replaying the oversized context forever. Never on a lock-contended defer — that is the OPPOSITE case (a concurrent path holds the lock and is shrinking it). Returns ``(response, session_entry)``.compression_deferreduCompression deferred for session %s — the compression lock is held by a concurrent compressor. Keeping the session intact; the next message retries normally.rVcompression_exhaustedrjNz4Keeping API session %s after compression exhaustion.rDz,gateway.session.auto_reset_context_exhausted) rXr\rcrSr5r API_SERVER_hmwa_defer_exhaustion_reset_hmwa_rotate_exhausted_sessionr)rqrrr{rtrur1s&&&&&&r+"_hmwa_compression_exhaustion_reset>GatewayTurnPersistenceMixin._hmwa_compression_exhaustion_resetFs   2 3 3 KKE-: ((s   &&  5 6 676:W[;\`h`s`s;s KKN4A 00s L &&   5 6 6=[44]QWXX&*&I&I-fl&m m  B!,Z*[[H&&!ns:/D%+D%7D%+D%D% D%-D%?D# D% D%c aaaa^RIHp\SRR4\P8wgVP 4'gR#^RIHpV!S4pVfR#VVVV3RlVPS&R#)ajTrue when the reset was handed to the authority drain. A LOCAL session (the Bot Chat a ``hermes peer dm`` lands in) resets its target in the store, which refuses while an admission on it is started (``session_busy``): this turn's own. The drain runs the reset right after it settles this admission, before it claims any successor (the Bot Chat's retry included).)executing_admissionrjNF)active_authorityc*<SPSSS4#r)r)rqrtrur1sr+JGatewayTurnPersistenceMixin._hmwa_defer_exhaustion_reset..os9\9\ ;:0r-T) gateway.session_ingressrr5r rrXgateway.session_authoritiesrdeferred_resets)rqrtrur1rr authoritysffff r+r8GatewayTurnPersistenceMixin._hmwa_defer_exhaustion_resetcs[ @ 6:t , >FYF]F]F_F_@$T*  20 !!+.r-c l"\PRVP4^RIHpHpV!WVP4GRjxL wrgV!WVP4GRjxL VP V4\VPV4;'gR4pVPVRR7V'd5VPV4PPPV4Ve.Tp\P!VP W1RR7GRjxL V!4V#LLL T!4i;i5i)zPThe compression-exhaustion auto-reset itself; returns the route's (fresh) entry.z7Auto-resetting session %s after compression exhaustion.)move_route_wakesreset_and_rehome_messagesNcompression_exhausted_resetrTzcompression-exhausted-resetr))r\rcrSgateway.session_automationrr_evict_cached_agentlist_overflow_queue_clear_conversation_scope_session_state conversation queued_eventsextendrnrorp) rqrtrur1rr new_entry release_freshqueueds &&&& r+r:GatewayTurnPersistenceMixin._hmwa_rotate_exhausted_sessionss M}OgOghZ)B4VcVnVn)o#o  "4m6N6NO O O  $ $[ 1$..{;AArBF  * *;?\ * ]##K0==KKRRSYZ$!* ''55vUr O=$p O* OsZ?D4D"D4 D(D$ 1D(!D(4A D(D&D( D4$D(&D(( D11D4c RRRVPe VPM VPRVPe VPMT/pVP'dVPVR&^RIHp/VP 'dRVP /M/CV!V4CpV'dWSR &\VR R4'd\VP4VR &V#) zQTranscript row for the inbound user turn (clean text + event time when captured).ruserrNrr)display_metadata_for_eventgateway_input_ownerdisplay_metadata message_id) persist_user_message message_textpersist_user_timestampr;rZr"persistence_ownerr5rar%)eventpreparedts _user_entryr"r$s&&& r+_hmwa_user_transcript_entry7GatewayTurnPersistenceMixin._hmwa_user_transcript_entrys F 191N1N1Z--** H<[<[* + 5, - -(+E,<,<(=K %r-c "^RIHp \P!4p VPpVPpVP pVP RVPRJ4pVPWV 4pV 'dEMhV'gVP\P8wdlTPTRRRVP R.4;'g.RV !4RVP'dVPPMR R V /4GRjxL V 'g V 'dVP'dVVPV\!VP44GRjxL 'd#\"P%R VPV4MVPVVVR 7GRjxL VP'WP)V44GRjxL EMVP R \+V44p\+V4V8dVVRM.pV'gHVPVVVR 7GRjxL V'd#VPVRRRVR V /VR 7GRjxL MRpVFpVP R4R8XdK/VCR V /CpV'gJVP R4R8Xd4VP'd"RV9d\!VP4VR&RpVPVVVR 7GRjxL K VP-VP.VP R^4\1\3VRR44'*R7GRjxL VP5WO4GRjxL R#ELEELELELEL>ELLL3L5i)zPersist this turn to the transcript (session_meta on first turn, user-only on transient failure, nothing on context overflow), update last_prompt_tokens, and re-baseline the cached agent's message count.)_resolve_gateway_modelagent_persistedNr session_metatoolsrLrjrDrz:Skipping duplicate user turn (message_id=%s) in session %s)skip_dbrrrFsystemr!r%Trinternal)rtouch_activity)rWr1rdrgrSrsrX _session_dbr.rjr rrvaluer%has_platform_message_idrar\rcrrreupdate_sessionrur(r5"_refresh_agent_cache_message_count)rqr*r1rtrurrrr+r{rrrr1r,storesidrsr2 _user_rowrR new_messages_user_msg_id_attachedmsgentrys&$$$$$$$$$$$ r+_hmwa_persist_turn_transcript9GatewayTurnPersistenceMixin._hmwa_persist_turn_transcripts- 7 YY[((&&""'**+N>NVZ>Z[44UbI & v(..@ 00N\--gr:@@b35 5 5b 7"%@###e.K.KCQTUZUeUeQf.g(g(gKKT((#  44S)_4]]]2238U8UVb8cddd+../?WN ?B>?RU`?`~kl;fh #44S)_4]]]#88&+y(KY[!\$39-2)+776?h6$ 83 8 R 8 5 #6 9 % 0 0 0 ,E 925e6F6F2GE,/481#88e_8]]] ,""  % %,:J:JK_ab:c#GE:u$EFF#   55kGGG{)h ^e^(^  HsBM&AM& M&'"M& M M&M&M&0(M&M M&#9M&M'M&M?M&M&M M&)M&M3M&;'M&#8M&M AM&.M"/M&M$M&M&M&M&M&M& M&"M&$M&c$V^8dQhRRRRRR/#)r&rrdictr{rar'r))r*s"r+r,r=s&UUUUUr-c ~VPR4'd V'gV#^RIHpV!WPR44#)zA usage-window refusal sent to a chat: credits steps point at the Portal (a chat's /topup has no Keep going control) and the reset reads as a duration (the gateway's clock is not the reader's). Every other reply is returned unchanged.usage_window_message)chat_refusal_wordingfailure_resets_at)rXagent.plan_limitsrK)rrr{rKs&& r+_usage_window_chat_wording6GatewayTurnPersistenceMixin._usage_window_chat_wordings7   !788XO:#H.>.>?R.STTr-c "VPWW4VWgWV 4 GRjxL p \VPR4\4'dVP WR,VVR7V #LF5i)z``_hmwa_deliver_turn_response``, then, for a usage-window refusal, the limit offer: the limit sentence is the reply, and the button follows it once it lands.N usage_limit)ru generation)_hmwa_deliver_turn_response isinstancerXrH_schedule_usage_limit_offer) rqr*r1rtrurwrrrr{ footer_lineintentional_silence delivereds &&&&&&&&&&& r+'_deliver_turn_response_then_limit_offerCGatewayTurnPersistenceMixin._deliver_turn_response_then_limit_offersq :: =~ (AT   l&&}5t < <  , ,U4O]h8F - H sA%A#AA%c "\V4'dR#V 'd#\PRVP4RpVP V4p V RJ;'d\ \ V RR4!WE44p V 'gLVPWV\ VPR44R7'dVPW4GRjxL VPR4'dVPR4'gV'd:V 'd2VPR 4'gVPWV 4GRjxL V 'd>V 'd6V PVPWPW4R 7GRjxL \!\4;_uu_4\#T;'gR4VnRRR4R#V#LLLF \d!p \PR T 4Rp ? LjRp ? ii;i +'giR#;i5i) zFinal delivery decisions: intentional silence, voice reply, streamed-turn media/footer. Returns the text for the adapter to send, or ``None`` when already delivered.Nz5Suppressing intentional silence marker for session %srD_streaming_tts_turn_completedcR#)Fr))_a_ks*,r+rIGatewayTurnPersistenceMixin._hmwa_deliver_turn_response..;sPUr- already_sent)rarmedia_already_delivered)metadataztrailing footer send failed: %s)rr\rcrS_delivery_adapter_forr(r5_should_send_voice_replyrX_send_voice_reply_deliver_media_from_responsesendr^_event_thread_metadatarir_r ra_streamed_final_response)rqr*r1rtrurwrrrr{ _footer_liner|adapter_streaming_tts_doners&&&&&&&&&&& r+rS7GatewayTurnPersistenceMixin._hmwa_deliver_turn_response+s ! ' '  KKOQ^QiQi jH,,V4%T1  d G<>U VWb s7 #t'D'D ^$|?O?OP^?_:`(E( ( ((9 9 9   N + +L4D4DX4N4NGL,<,<=V,W,W77QQQH!,,v~~|NiNijoNx,yyy )$$14X^^1D.%+ :Rz HLL!BBGGH%$sH=H%HAHF? H$H;HH H"H7G8 HH /G<G=GHG33 HHG G0G+&H+G00H3 H > Hzgateway.errors.hint_authizgateway.errors.hint_quotaizgateway.errors.hint_overloadedc &"VPW#4GRjxL \PRV4\VRR4pVR%9d4\ VP 4^28d^RIHp^RIH p V !V!44#VPeVeVPPVPVP4GRjxL p V 'gRVPPVP VP#W&\$P$!444GRjxL VP'VP \(4GRjxL TP.P1T4p T 'dTR 8wd \3T 4MR p TR 8XdL^R IHp \TP9T4P:R R4p\3Y!\TRR44R7p EMMTR8Xd/p\=\*4;_uu_4TP>PA4P1R/4pRRR4\CT\D4'g/pTP1R4pTP1R4R8wd \3R4p MT'd0T^8d)^RI#p\3RTPITR, 4R7p Mx\3R4p MlTR8Xd \3R4p MY\TRR4R8XdH\TRR4'd5RTPJ RTPL R TPN;'gR! R"2p ^RIH p T !TPQ\3R#T R$7\(44#EL1ELEL6EL \*d\P-RRR 7EL4i;i +'giELm;i5i)&z``except Exception`` body of the agent turn: stop typing, log, persist the inbound user turn once, and build the sanitized user-facing error reply.NzAgent error in session %s status_code)_context_overflow_reply)record_unexecuted_failurezrr))_hmwa_stop_typing_for_turnr\ exceptionr5rersrWrsgateway.session_resultsrtr'rghas_input_ownerpersistence_session_idr)rrSr.rdrrrir_ _STATUS_HINTSrXragent.turn_failure_copyrurturnr r{jsonrTrHmathceilrUr}detailr)rqrr*r1rtrur+rqrsrt_owned _hint_key status_hintru _turn_agent _err_json _resets_inrs&&&&&&& r+_hmwa_agent_error_reply3GatewayTurnPersistenceMixin._hmwa_agent_error_reply`s --e<<<4kBa5 * $X-=-=)>)C < I,-D-FG G h$$0]5N#77GG33X5O5O 22GG%00$2R2RSXdhdmdmdo2p22=3K3KMghhh&&**;7 &/K34Fa lB #  D!$"5"5k"B"G"GRVWKI/CGKYceiDj/klK C I)$$JJOO-11'2> %i.. "':;J}}V$(== BC  Q HPTPYPYZdgkZkPlm  AB C :;K Q$ '+K KPWXY[bdhPiPiahhZr!''"QXX5N5N4OrRKE()J)J 7k JLf*   i =i h LLWbfL g h%$$sNMA!N:AM?M  M A MM'MMM"N(BN.+M=AN4B N4N MMM"M:6N9M::N= N  Nc \PRT;'gRV4VPVPV4W#4R#)zVA newer run generation superseded this turn: drop its deferred post-delivery callback.uKDiscarding stale agent result for %s — generation %d is no longer currentrVN)r\rc_pop_post_delivery_callbackrd)rqr1rvrws&&&&r+_hmwa_discard_stale_result6GatewayTurnPersistenceMixin._hmwa_discard_stale_results; Y   #~  (()C)CF)KZhr-r))NN)z%gateway.reasoning.quote_label_discordz-# z-#)z gateway.reasoning.quote_label_mdz> >)__name__ __module__ __qualname____firstlineno__rrrrrrrrrrrr staticmethodr.rErNrYrSrrr__static_attributes__r)r-r+r9r98sZ>| IE +\Z.;>A "  #\J': #J4]H~UU *` ' ( -M : xir-r9)F__doc__ __future__rloggingtypingrrn dataclassesinspectrosqueue threadingrd agent.i18nrrrrrragent.session_activityr contextlibr r contextvarsr gateway.configr rrgateway.platforms.basergateway.platforms.eventrgateway.sessionrrrrgateway.session_transcriptrgateway.turn_contextrgateway.warning_notificationsrgateway.turn_leaserrhermes_constantsrpathlibrrrrrr r!utilsr"rWr#gateway.run_turn_runnerr$ getLoggerr\r7r9r)r-r+rsE"   =,$#I60;,?H5==#)2   = )j ij ir-