+ iHj2JRt^RIHt^RIHtHt^RIHtRRltRRlt R#) a``message.complete.persisted_turn``: the committed row addresses of the agent's current turn. Shared by every host that publishes a turn's completion (the TUI gateway's in-process turn and the session authority's TurnRunner turn), so a client sees one receipt contract whichever host ran the turn. Clients key on it to bind a streamed reply to its stored row (``SessionMessage.row_id``) instead of comparing words. ) annotations)AnyCallable)_DB_PERSISTED_MARKERc V^8dQhRRRR/#)messagerreturnz int | None)formats"A/home/ubuntu/.hermes/hermes-agent/agent/persisted_turn_receipt.py __annotate__r shhchjhc\V\4'dVPR4MRpVP\4'd\ V4\ Jd V^8dV#R#)_row_idN) isinstancedictgetrtypeint)rrow_ids& r committed_row_idrsM'1'4'@'@W[[ #dF[[!5664<3;NSY\]S]6gcggrc8V^8dQhRRRRRRRRRRR R R R R R/#)rmessagesrstarthistorylistrawstatusstrcompression_unchangedboolprefix_row_matcheszCallable[[Any, Any], bool]r z dict | Noner )r s"r r r sN----(,-36-@C--5O--rc aaa\V\4'dh\V4\JgU^Tu;8:d\ V48d=MR#\W,\ 4'dW,P R4R8wdR#WRo\S^,4o\;QJd VV3RlV4F 'gK RM RM!VV3RlV44'dR#SUu.uFp\V4;pfKVNK p pV 'gR#RV RR/p \S^,4;p eWR &SUu.uF4qwP R4R8XgKVP R 4R 8wgK2VNK6 p pV Uu.uFp\V4NK p pV 'd RV 9dWR &SR,pVR8XdWVP R4R 8XdAVP R4'g*VP R4V8Xd\V4;peWR&V\ V48H;'dS\;QJd+V3Rl\W RV44F 'dK RM RM!V3Rl\W RV444p\T;'dLT;'dB\ V 4\ S48H;'d#\RS44^8H;'dRV 94V R&V #uupiuupiuupi)aReport committed row addresses, never a text/timestamp search for a matching turn. ``start`` is the agent's persistence cursor (``_persist_user_message_idx``), re-anchored during compaction. A partial receipt can address its surviving rows, but cannot retire a client's entire streamed turn. Full coverage additionally requires the unchanged pre-turn prefix (``prefix_row_matches(history_row, turn_row)`` for every row before ``start``), no compaction and no redirected user boundary. roleuserNc3~<"TF2pVS^,J;'gSRJ;'dS\V48HxK4 R#5i)N)r).0before anchor_idtails& r )persisted_turn_receipt..%sE " v T!W  a a$!6!`!`9HXY_H`;` a s = ==TFrow_idscomplete user_row_id display_kindhidden user_row_ids assistant tool_callscontentfinal_assistant_row_idc38<"TFwrS!W4xK R#5i)Nr )r(r)afterr"s& r r,r-:s!5_?]mf6))?]sc3H"TFqPR4R8HxK R#5i)r$r%N)r)r(rs& r r,r-?sBT' F#v-Ts ") rrrrlenrrranyallzipr!sum)rrrrrr r"rridr.receiptr0usersr3lastfinal_idprefix_unchangedr*r+s&&&&&$d @@r persisted_turn_receiptrGs x & &$u+S*@UHbUXYaUbHbhot448K8KF8SW]8] F D a)I s "  "sss "  """"&Y$w2B72K+K3ss$GY U;G'Q00 =!, %) vDKK,?6,IWgkkZhNimuNuWWDE v=BCU'$W-ULC \)". 8D*&!1[!@R^I_I_#s*rLs # 9h -r