+ jHj8Rt^RIt^RIHt^RIHt^RIHtHtH t H t H t H t H t HtHtHt]!0Rm4t]!0Rm4tRtRtRtRtR tR tR tR tR tRtRtRtRt R#)a{Steer and Edit of a still-queued admission: ``prompt.steer_queued`` / ``prompt.replace_queued``. Both consume the queued row inside one owner write transaction, so it can never also run as its own queued turn, and a retry replays the recorded outcome. There is no reorder verb: one FIFO per session. A steer is a TRANSFER to the running claim, not an outcome: the row goes queued -> terminal ``steering`` bound to the claim's generation, and settles with that claim (``steered`` once the claim completes with the text delivered, ``interrupted`` otherwise; queued again in its own FIFO place when the text never reached the claim's agent). The fence is ``authority.steer_transfers``, changed only under the session's ``event_stream.lock`` (the lock the drain clears ``executing`` under): no storage write ever waits under that lock, which loop-side receipts, attaches and publication take. N)asdict)partial) STEERINGRuntimeStoreErrorcheck_replaced_inputfind_session_admissionget_session_admissionreplacement_bindingretire_replaced_inputrevert_steer_inputsteer_replayedsteer_session_inputcFR\\V4R\\V4/#)zprompt.steer_queuedzprompt.replace_queued)r steer_queuedreplace_queued) connections&D/home/ubuntu/.hermes/hermes-agent/gateway/session_queued_controls.pyhandlersr!s& !7<#D #W^Z%H JJc$VPpW9d^VPP4;_uu_4pVPRV34P 4pRRR4XfR#V^,W!&W!,\ 9# +'giL0;i)aThe session's frozen launch source (a local session's row records it) names a local surface. Callers hold the stream lock: one plain read per session, cached (``get_session`` flushes token counts, a write). Under WAL it takes the lock-free reader pool, as ``_pending_rows`` does there.z&SELECT source FROM sessions WHERE id=?NF)launch_sourcesdb _read_ctxexecutefetchone_INTERACTIVE_SOURCES) authority session_idsourcesconnfounds&& r _interactiver!&sw&&G \\ # # % %LL!IJ=YbbdE& =#Ah  "6 66 & %s "A?? B cVPR4;'g/pVPR4pVPR4R8wg\V4\, 'gt\V\4'd^VP 4'dHVPR4;'g/PR4R8Xg\ WR,4'g.#R R .#) zThe queued-row verbs this owner serves for ``row``: a client shows only these (an older owner lists none, so its clients show none).payloadtextstatusqueued display_v1kindhiddentarget_session_idsteerreplace)getset _TEXT_ONLY isinstancestrstripr!)rrowr#r$s&& rqueued_controlsr44sggi &&BG ;;v D X%W )B)B*UY[^J_J_gkgqgqgsgs L)//R44V<H /B+CDD Y rcVPV4Uu/uF q"R,VbK ppVPPVP4pVe V^,MRFHp\ VP VR7pVfK VR,R8XgK0VR,\ 8XgKDW#V&KJ \VP4RR7#uupi) aThe pending rows a viewer is shown, plus each queued admission in transfer to the running claim: listed ``started`` and ``steering``, because it may still go back to its queue place, and a client must not retire an admission it no longer sees. The caller holds the stream lock. admission_idr6r%terminaloutcomecVR,#)seq)r3s&rpending_rows..JsUr)keyr<) _pending_rowssteer_transfersr-rrrrsortedvalues)rrefr3rowsentryr6s&& r pending_rowsrG@s1:0G0G0L M0L  $0LD M  % % ) )#.. 9E$)$5a2= #ILL|L ?s8} :s9~QY?Y!$ > $++-%; << NsCc"VPPVPW4GRjxL pV\VPPVR73#L'5i)Nr7)rreceiptactorrr)rrDr6rIs&&& r_queuedrKMsL((001A1A3UUG )**>*>*A*AP\] ]]Vs*AA(AcVPPV4pVeV^,V8wdR#VPPVR4wrEWB8Xd\VRR4MRpV^,P 4F>wrxV'gK\ V4'gK"V!V4'gK2RV^,V&K@ \ V^,4#)a``{admission_id: delivered}`` handed to this claim; the caller holds the stream lock. Read by the claim's settlement after its execution returned, when no transfer can still be delivered. The agent settles each one by its ticket (the admission id), never by its text: one no drain of the turn consumed (still buffered, or dropped unread) reads undelivered and goes back to its queue.Nwithdraw_steerFNN)rAr-adoptedgetattritemscallabledict) rr generationrFadopted_generationagentwithdrawr6 delivereds &&& rrArARs  % % ) )* 5E }aJ. ) 1 1 5 5j, O9K9Ywu.5_cH#(8>>#3 9(++0F0F%*E!H\ "$4 a>rcVPPV4pVeV^,V8wdV/3;q@PV&V^,PVR4R#)z;``{admission_id: delivered}`` for the claim ``generation``.NF)rAr- setdefaultrrrTr6rFs&&&& r _registerr\bsT  % % ) )* 5E }aJ.9CR8HH))*5 !H e,rcVPPV4pVe;V^,V8Xd+V^,PV4RJd V^,VR#R#R#R#)NF)rAr-r[s&&&& r _unregisterr^jsV  % % ) )* 5E U1X3a \8RV[8[ !H\ "9\3rcVPPVR4wr4W28wg=VPPV4V8wg\\ VRR44'gR#V#)zThe agent the running claim adopted, while that claim still executes. None before adoption (a latched text would be dropped if construction then failed) and for a turn with no steer seam.Nr+rN)rOr- executingrRrP)rrrTrUrVs&&& r_receiving_agentraps[!* 1 1 5 5j, O(I,?,?,C,CJ,OS],]GE7D9:: LrcVPPV4pVe,V^,V8wgWF^,9g\WV4VJdR#V^,V,'gU\\ VRR44p\ V'dVP WTR7MVP V44V^,V&V^,V,#)zHand the committed text to the claim's agent; the caller holds the stream lock. False once the claim stopped executing (its settlement then decides the row) or its agent refused the text.NFrM)ticket)rAr-rarRrPboolr+)rrrTrVr6r$rFticketeds&&&&&& r_deliverrfzs  % % ) )* 5E qZ/4J|  ((#/@A ,??LGc y>X %##CNN3@@EEE(NNC DUV$YL8I5`cdm`nou`vwFg~~! 344oi55 566   s #F *//#88#i.:PR[RdRdehesesRtdJJ       C =#$7~+^` `)B > !.y' Y__S_;x"yy     # # #  E<^I$ 73Ey||[d[j[j@L,ef f f""'''I:L(  & &s +    $#$7~+_a a""3' )$$Y/ 00e@FEE  y    # # #  z H$ $ # $ # # f'''sAO8M A"O8&AM 5CO8+M 9O81M79M4:M7O8O8&O 5O81O86O!7"O8 O$&A$O8 M  O8 M1 + O84M77)O  N6- O 6 O  O  O8 O  O8$ O5 / O8cVPPVP4pVPPVP4pVeVeV^,V8wdR#VPP ;_uu_4VPP VPR4RRR4V^,Fcp\VPVR7pVfK VR,R8XgK0VR,R 9gK@TPYVR,R8XdRMRR7Ke VPV4R# +'giL;i) zAfter the claim's settlement: each admission it carried publishes the outcome it settled to (``steered``, or ``cancelled`` for an interrupted transfer, as a turn's completion reports it).Nr7r%r8r9steered cancelled)r9)r interrupted) rrr-rrArsrtpoprr_settle_cancelledry)rrDrTr~rFr6r3s&&& rpublish_transfersrs    ! !#.. 1D  % % ) )#.. 9E |u}aJ(>     !!%%cnnd; a #ILL|L ?s8} :s9~Qk?k  ' '=@^y=X ^i ( k! s# s 'D33 E c "VPVPVR,rTpTPYP4UUu/uFwrgVR8wgKWgbK upp4p\ WV4GRjxL wr\ P !\VPVPVPVPR7GRjxL p V fTV PR8wd \R4hR\W:49d \R4hVPP!V4M(V PV P"3R8wd \R4h\%VPVPVP4p VP'WHVP(R J\+\,W\R 7\+\.W\R 7R 7GRjxL p \1VPVR 7pWSP9d*VR ,VR,3R8XdVP3W4M)VR ,R8XdVPP5V4^RIHp\ P !WPV4GRjxL \;V 4#uuppiELELL \1TPTR 7pYSP9d*TR ,TR,3R8XdTP3Y4iTR ,R8XdTPP5T4ii;iL5i)ayCancel the queued admission and admit the edit at the FIFO tail under a new identity, in one write. The replacement is bound to the admission it retired: an exact retry (same old admission, same new ``submission_id``) answers the same new admission; any other old admission under that ``submission_id`` is ``admission_conflict``, decided inside the admission's own transaction.r6N) principal_idr request_idr&rhr,riadmission_conflictT)r6binding)queue_while_restarting_authorize_write _replay_guardr7r%r9)release_admission_media)r8r)rrJ submissionrQrKasyncio to_threadrrsubjectrrr%rr4cancel_obligationsaddr9r submit _operatorrr rrrdiscardgateway.session_ingress_mediarr)rrDr|rrJold_idr?valuerequestrIr3 replacementradmittedoldrs&&& rrrs *33Z5E5EvnG]fI##C||~)o~Y\`nYn*#*~)opG &99LG))*@),,]b]j]j58^^PWPbPbddK >>X %#$78 8 OI; ;#$9: :$$((0 ..'// *.G G 455!%--ASASTG 9"))%Q[QeQeimQm;BCXgm;8?@Tci8{*}}$ILLvF 11 1s8}c)n6UYr6r  ' ' 4 ]h &  ( ( 0 0 8E   3\\6 JJJ ( 3*p9d}$ILLvF 11 1s8}c)n6UYr6r  ' ' 4 ]h &  ( ( 0 0 8'Ksp?K8 I) I) K8.I//AK8?I2B.K8/AI71I52I76B#K8K6K82K85I77Ar$r' surface_v1local_operator_v1>acpcliguituidesktop)!__doc__r dataclassesr functoolsrhermes_state_runtimerrrrrr r r r r frozensetr/rrr!r4rGrKrAr\r^rarfrrrr<rrrs P Q !!HIJ 7   =^  -#  "51p$"r