+ jHj!Rt^RIt^RIHt]P!]4tRtRtRt Rt Rt ^t Rt R tR tR R ltR#) aThe messaging setting handlers (``/reasoning`` ``/busy`` ``/verbose`` ``/fast`` ...) on a LOCAL session. ``slash.exec`` runs the same ``_handle__command`` a messaging chat runs. A local session's next turn reads its settings from its live session and frozen policy, not from the runner's per-platform snapshot, so a handler that changes a setting also applies it here: one behaviour for every surface, held by the gateway. N)SimpleNamespacec&\W4^,#)z\The ``LiveSession`` of the local session ``source`` belongs to, else None (messaging chats).)local_authority_live)runnersources&&E/home/ubuntu/.hermes/hermes-agent/gateway/session_setting_commands.py local_livers  / 22c<\W4fR#^RIHpV!W4#)z0The frozen policy of a local session, else None.Npolicy_for_source)rgateway.session_policyr )rrr s&& r local_policyrs&!)8 V ,,r cj\VRR4pVR 9dV#^RIHpV!WP4pVe\VRR4R8XdRMRpVfVP VP4#VP 4P R4;'g/P R4;'gTpVR 9dV#T#) zYThe busy mode a local session's next input runs under (what ``config.get busy`` reports).busy_input_modeN interruptqueuer rtuidisplay)rsteerr)getattrr r r_effective_busy_input_modeconfigget)rlivevaluer policyfallbacks&& rsession_busy_moders D+T 2E // 8 v{{ 3F !,41PTY1Yw_jH ~00== ]]_  + 1 1r 6 67H I U UXE<<5J(Jr c"V'gR#^RIHp^RIHpV!V4Flp\ \ VR/4P 44FApVPV8XgKVPPVP8XgK=Vuu# Kn R#)zDThe local ``LiveSession`` whose route is ``session_key``, else None.NPlatformall_authoritiessessions) gateway.configr!gateway.session_authoritiesr#listrvaluesrouterplatformLOCAL)r session_keyr!r# authorityrs&& rlocal_live_for_router.-sj ';$V, J;BBDEDzz[(T[[-A-AX^^-S F- r c,^RIHpVe\VRR4VP8wdR#^RIHpV!V4FYp\VR/4P VP4pVfK/VPPVP8XgKVWE3u# R#)z\``(authority, live)`` owning the local session ``source`` belongs to, else ``(None, None)``.r Nr*r"r$)NN) r%r!rr+r&r#rchat_idrr*)rrr!r#r-rs&& rrr:s~' ~T:hnnL;$V, y*b155fnnE   4 4 F? "- r c ^RIpRVPRRVP4P,RVR,RVR,R R R R V//#) zaThe owner's fenced ``reasoning`` mutation of a ``/reasoning`` command, on *row*'s current fences.N session_id request_idzreasoning-command:expected_revisionruntime_revisionexpected_generationruntime_generation operation reasoningpayloadeffort)uuidr2uuid4hex)refrowr;r<s&&& r_reasoning_mutationrAJsU #..,8Ltzz|O_O_8_ %7!8:OQTUiQj i(F1C EEr c "^RIp^RIHp^RIHp^RIHp^RIHp ^RI H p VR8Xd V'gRp MVR8wdV!V4eTp MR#VPVP,p V PPVP8wdR#\!\"4Fep VP%VP&P(VP4GRjxL pVf V !R4hV!WV\+W.V 44GRjxL R# VP.V 3V nR#LGL T .T O5d/p\-TR R 4pTR 8XdRp?KTR 9dhRp?KMRp?ii;i5i) aR``/reasoning `` in either scope, or ``reset``, on a LOCAL session (``config.set`` and ``slash.exec``): the owner's fenced ``reasoning`` mutation, before the handler replies or writes config.yaml (``--global``). The level is the session's durable choice and a reset gives it back to the profile, whatever an older pick said, after an owner restart too. Display words and reads commit nothing, and so does a messaging chat (no session policy). While a turn runs, the handler applies it for the next turn as on main and the drain commits it at that turn's end (``apply_pending_reasoning``).Nr )mutate_session)parse_reasoning_effortMUTATION_GUARD_REFUSALSRuntimeStoreErrorreset not_foundreason session_busyrevision_conflictrLunknown_execution)asyncior%r!gateway.session_mutationsrChermes_constantsrDhermes_state_mutation_guardsrFhermes_state_runtimerHr$r2rr*r+range_FENCE_ATTEMPTS to_threaddb get_sessionrArsubjectpending_reasoning)r-actorr?rpersist_globalrPr!rCrDrFrHr;r_attemptr@excrKs&&&&& rcommit_reasoning_commandr`Rs7'87D6  ' 4U;G   cnn -D {{x~~-/*%%ill&>&>OO ;#K0 0  38KCV\8]^ ^ ^  +$mmV4DP _!<$;< S(N;F,,BB   s_1EB"EDE(D"?D D"E D"" E-EEEEEEc "^RIp^RIHp^RIHp^RIHpVPRuqrnVfR#VPVPPVP4GRjxL pV!W\WV^,4RV^,R7GRjxL R#L2L T.TO5djp \T RR4R 9d"TP;'gTTnRp ? R#\PRTPT P 4Rp ? R#Rp ? i\"d%\P%R TP4R#i;i5i) zCommit a reasoning command that arrived while a turn ran. The drain calls this at the turn boundary, under the claim gate and mutation lock, before a deferred model pick (whose level wins, as on main).N)write_mutationrErG) principal_idrKrLz)Reasoning command on %s not committed: %sz(Reasoning command on %s failed to commitrN)rPrQrbrSrFrTrHr[rWrXrYr2rArloggerwarningrK Exception exception) r-r?rrPrbrFrHpendingr@r_s &&& rapply_pending_reasoningri|s 8D6&*&<&&>OOY-@7ST:-VX\krstkuvvvPv  8 7 8d 3. 15Z Z%)%;%;%F%FwD " " NNFX[XbXb c c UCS^^TUsv0E3B&B'+BBBEBB D>($D  D E+D E D>!D>:E=D>>Ec ^RIp^RIHp^RIHp^RIHpVPPp\V!VPV4R,R7p RVP;'g VP/p VP'dVPV R&V'dW:R &V!W V!VPV4R R VP4P ,R V /4R#) aUA typed ``/model`` on a local session: the resolved target becomes the session's canonical ``model`` mutation, committed by the owner at the next turn boundary (the typed command is itself the running admission). One writer, so the next request, ``sessions.model`` and ``session.info`` move together, or the commit is announced as a refusal.N) SessionRef) defer_pick) local_receiptrc)rZmodelproviderr9r3z typed-model:r:)r<gateway.session_contractrkgateway.session_deferred_pickrlhermes_state_localrmrr0rrXresolved_via_alias new_modeltarget_provider profile_idr=r>) r-rresultr;r<rkrlrmsidownerr:s &&&& rdefer_local_model_pickrzs 380 ++  C M),,$D^$T UE11EEV5E5EFG $44  % yI,@,@#!Fntzz|/?/??GTVr ))__doc__loggingtypesr getLogger__name__rdrrrr.rrVrAr`rirzr rrs[!   8 $3 -K$  E'5TU.Vr