+ jHjW4JRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI H t ^RI H t ^RIHtHtHtHtHt^RIHt^RIHt^RIHt^R IHt^R IHt^R IHt^R I H!t!^R I"H#t#^RI$H%t%]'d^RI&H't']PP!R4t)!RR4t*R#)zKExtracted gateway session_execution responsibility; consumed by TurnRunner.) annotationsN)suppress)datetime) TYPE_CHECKINGAnyDictListOptional)_accepts_keyword)#strip_stale_dangerous_confirmations)Platform)(repair_explicit_computer_use_media_paths)BasePlatformAdapter)api_runtime_locked) TurnContext)cfg_get)is_truthy_value) GatewayRunnerz gateway.runc]tRt^!t]P !RR44tRRltRRltRt Rt R t R R lt R t R tRtR#)GatewaySessionAgentMixincB]tRt^$t$RtR]R&RtR]R&RtR]R&RtR#) +GatewaySessionAgentMixin._CachedAgentLookupNragentFboolreusedevicted) __name__ __module__ __qualname____firstlineno__r__annotations__rr__static_attributes__r>/home/ubuntu/.hermes/hermes-agent/gateway/session_execution.py_CachedAgentLookupr$s sr#r%cV^8dQhRR/#)returnrr)formats"r$ __annotate__%GatewaySessionAgentMixin.__annotate__*s W W4 Wr#c ^RIHpV!VPVPP4pV'd VP #VPP PR4;'g/PR4;'g/p\V\4'gR#\VPV4;'g/PR44#)zgateway.platforms..skip_context_files: messaging platforms may opt out of filesystem-heavy context-file discovery (SOUL.md, AGENTS.md, .cursorrules).policy_for_sourcegateway platformsFskip_context_files) gateway.session_policyr._runner_ctxsource ignore_rules user_configget isinstancedictr)self platform_keyr.policy platforms_cfgs&& r$_skip_context_files,GatewaySessionAgentMixin._skip_context_files*s ="4<<1A1AB && &..229=CCHHU[[Y[ -..]&&|4::??@TUVVr#cV^8dQhRR/#)r'r(tupler)r)s"r$r*r+8sr#c VPpRpV'dTVePV;_uu_4VPVP4pRRR4X'd\V4^8d V^,pRpVerVPedWCP8wdT\ \ 4;_uu_4VPPPWCPR7pRRR4WF3#WF3# +'giL;i +'giYF3#;i)u(peeked cached session_id, is_dead) — checked OUTSIDE the cache lock. "cached sid != current sid" normally means an intentional switch (reuse), but the routing-key self-heal yields the same shape with an agent bound to a DEAD session; reusing it re-binds the dead sid and loops.NF) session_key) r4r8rDlen session_idr Exceptionr3 session_store_is_session_ended_in_db)r; cache_lockcachectxpeek_sidentrydeads&&& r$_cached_sid_is_dead,GatewaySessionAgentMixin._cached_sid_is_dead8sii %+ #//2Ua 8  CNN$>8~~C])$$||11II(`o`oIp%~x~%$~sC$%1C7$ C4 7 D c VPpVPPeVP'gR#Rp\ \ 4;_uu_4VPPP PVP4pV'dVPR^4pRRR4V# +'giT#;i)zRCross-process write guard input: the session's current DB message_count (or None).N message_count) r4r3 _session_dbrFrrG_db get_sessionr8)r;rLcountrows& r$_current_message_count/GatewaySessionAgentMixin._current_message_countKsii << # # +3>>> i ,,**..::3>>JC3 !  !  s AB00 C c ^RIHpVPPP VP P R4p\V\4'dV'd V^,MRpV'dW1JdV#R#)aEvict under the lock but DEFER release (release_clients can block on memory-provider / socket teardown while the idle sweeper waits on this lock). The turn rebuilds a fresh agent, so the caller does a SOFT release that keeps sandbox / browser / bg processes.)_AGENT_PENDING_SENTINELN) gateway.runr\r3 _agent_cachepopr4rDr9rB)r;r\rrs& r$_pop_cached_agent_for_eviction7GatewaySessionAgentMixin._pop_cached_agent_for_evictionXsX 8,,++// 0E0EtL(%88W $%"FuPDPr#c  VPpVP4p V'dVfV #T;_uu_4VPVP4p V 'dV ^,V8Xg V uuRRR4#\ V 4^8d V ^,MRp \ V 4^8d V ^,MRp V RJ;'d%VP RJ;'dWP 8gp V 'd2V'd*W8Xd$\ PRVPV 4EMV 'g1V e-Ve)W{8wd#\ PRVPW4MV ^,V n\VR4'd<\\4;_uu_4VPVP4RRR4VPPV PVP4WIPn\ P#RVP4RV nV uuRRR4#VP'4V nRRR4V # +'giL;i +'giT #;i)NuAgent cache invalidated for session %s: cached agent's session_id %s is ended in state.db (stale self-heal artifact, #54878 x #54947) — discarding instead of reusing across the routing recoveryzfAgent cache invalidated for session %s: message_count changed (%s -> %s), possible cross-process write move_to_endz#Reusing cached agent for session %sT)r4r%r8rDrErFloggerinforhasattrrKeyErrorrcr3_init_cached_agent_for_turn_interrupt_depthmax_iterationsdebugrr`r)r;sigrJrKrjrMrO msg_countrLoutcached cached_mc cached_sid sid_mismatchs&&&&&&&& r$_lookup_cached_agent-GatewaySessionAgentMixin._lookup_cached_agentasii%%'u0J ZYYs/FvayC/Z &)[1_q $I&)&kAo4J&T1qqcnnD6PqqU_cqcqUqL)? : BZ[^[j[jBk ) :>v?X?X&..:Y6Y kp !11 FIEZEZ %7$>$>$  ago.>v.FP[P[\#)#;#;EE@D  . =C ~~ 1= KK .1__ IL  KK ,/== EHMM ^a]j]j !$ v115&:L:LM! &$6#7#74T\\=a=a=c' ( 2) ,$((F(F63F3F#GG- .V;;(;(;rsnQ"   ;;3D#I67,%!)   = )I#I#r#