+ jHjIRt^RIHt^RIHtHt^RIHt^RI H t ^RI H t H t ^RIHtHt];QJdR.R]P$!R^4^,P%R ^4^,P%R 44FNK 5MK!R]P$!R^4^,P%R ^4^,P%R 444t]!0Rm4t!R R 4tR #)aIn-place row-rewrite persistence for the proactive prune (#124102). Split out of :mod:`hermes_state_messages` (FILE_LINES ratchet): the prune's own commit primitive and its lease-less staleness probe. Both are ``SessionMessagesMixin`` methods; this sibling defines a ``SessionPruneRewriteMixin`` the facade binds into the same MRO slot, so every existing ``session_db.rewrite_pruned_rows(...)`` / ``rewritten_held_row_ids(...)`` call site and test patch seam keeps working unchanged. ) annotations)AnyOptional)_DB_PERSISTED_MARKERDB_ROW_SNAPSHOT) _id_chunks _placeholders)_INSERT_MESSAGE_SQL_parse_tool_callsc#@"TFqP4xK R#5iN)strip.0columns& ?/home/ubuntu/.hermes/hermes-agent/hermes_state_prune_rewrite.py rsc!avLLNN!as(),cF]tRt^tRtRRltRRltRR/RR lltR tR#) SessionPruneRewriteMixinz]``SessionDB`` mixin: the proactive prune's in-place row rewrite and held-row staleness probe.c$V^8dQhRRRRRR/# session_idstrheldzlist[dict[str, Any]]returnz list[int])formats"r __annotate__%SessionPruneRewriteMixin.__annotate__s(KKKASessionPruneRewriteMixin.rewritten_held_row_ids..2s11$ DIr$)_read_retrying_ioerr)r)rrsfffrrewritten_held_row_ids/SessionPruneRewriteMixin.rewritten_held_row_idss((( IK Kr$c$V^8dQhRRRRRR/#rr )r!s"rr"r#4s(OOCO?SOXaOr$c  ^RIHp^RIHpRRlpVUu.uFYp\ V\ 4'gKVP \4'gK8VP R4R9gKPWv!V43NK[ ppVUU u/uF wryV fK WbK p pp /p VFHwryV eK \ VP \4\4'gK6V!V4p V fKDW{V &KJ V'dV 'g V 'g.#/p \V 4FOpVPR\V4 R2V.VO54P4FpW\VR,4&K KQ /pV P4FUwrVPR W'P R4V 34P!4pVfK<VVV &W\VR,4&KW .pVEFwryV eV P V 4M TP V!V4;'gR 4pVe#\VR ,;'g^4'gKdVP \4p\ V\4'd1V!V4V8wd"VP#\VR,44KVP%VP RR 4VP R 4VP R4\'VP R444pVP%VR,VP)VR ,4VR,\'VR,44pVV8wgEKkVP#\VR,44EK V#uupiuup pi)uP``rewritten_held_row_ids`` against *conn*: the same CAS compare, on a connection the caller already holds (inside a ``BEGIN IMMEDIATE``, the full writer's commit window — a precheck outside that lock misses a write that lands between check and commit, and the full writer would then archive that newer row and republish the stale held text, #124102). Chunked like ``stamp_inserted_row_snapshots``: one ``id IN (...)`` per ``_id_chunks`` batch, so a long history stays under SQLite's host-parameter limit instead of failing the pass. Rows without an exact ``_row_id`` but with both the persist marker and a CAS snapshot are resolved by their logical ``message_uid`` (``idx_messages_session_uid``): the unaddressed live-replay loaders stamp exactly that pair, and a rewritten-in-place row is as lost a race there as a row-addressed one (#124102). )message_uid_or_nonetranscript_row_snapshotc V^8dQhRRRR/#)rmessagedict[str, Any]rz Optional[int]r )r!s"rr"BSessionPruneRewriteMixin.held_row_mismatches..__annotate__Ds  ~ - r$cVPR4p\V\4'd \V\4'g V^8dV#R#)_row_idN)get isinstanceintbool)r5rids& r _exact_id?SessionPruneRewriteMixin.held_row_mismatches.._exact_idDs7++i(C#s##JsD,A,AcAg r$rolez7SELECT * FROM messages WHERE session_id = ? AND id IN (ridztSELECT * FROM messages WHERE session_id = ? AND active = 1 AND role = ? AND message_uid = ? ORDER BY id DESC LIMIT 1activeunknowncontent tool_call_id tool_calls)user assistanttool)agent.message_metadatar1agent.transcript_repairr3r;dictr:_DB_PERSISTED_MARKER_KEYrrrexecuter fetchallr<itemsfetchoneappend _row_identityr _decode_content)r)r(rrr1r3r?r5exactrow_idby_idby_uiduidstoredchunkrow by_uid_row mismatchessnapshot held_identitystored_identitys&&&& rr',SessionPruneRewriteMixin.held_row_mismatches4s  ?C  F'4( *-4[[9Q-R * F#'DD *Wi( ) F 9>T_WT $OG~*W[[-I3"O"O)'2?")3K % %6I!#&E||I-X]J^I__`a$e$&&.hj1*-s3t9~&1' &( "LLNLC,,+[[0#689A  "% 3),s3t9~&+!# $OG(.(:&**V$ ObcjOkOqOqoq@rC{#c(m&8&8q"9"9{{?3H(C((*3/8;%%c#d)n5 .. FI. I0F TbHc!'++l";<>M#00F T11#i.A3~CV!#l"346O/!!#c$i.1! %"sF Us"MMM) M=M$ M$model_config_patchNc(V^8dQhRRRRRRRR/#) rrrchangesz+list[tuple[dict[str, Any], dict[str, Any]]]rezOptional[dict[str, Any]]rr<r )r!s"rr"r#s1F>F>cF>4F>@CF>r$c  aaaaaaa a a a a ^RIHo^RIHo^RIHo ^RIHo Ho RRlo RVVV V V VVV 3Rllo VV V VVVVV 3R lpSPS4SPTSUUu.uFwrVVNK upp4#uuppi) uBProactive-prune commit that rewrites only the changed rows, in place (#124102). ``archive_and_compact`` is a generation writer: it archives every active row and re-inserts the whole list, which is right for summary compaction (the row set changes) but makes each prune grow the store by the full live transcript although a prune only edits a few rows' content. Each ``(original, replacement)`` in *changes* is a persisted message the prune edited. Its row is named by ``original["_row_id"]``, else by its tool call id (tool results) or tool-call ids (assistant turns), else by the single active row with the same role and stored content. That row gets one archived twin of its pre-prune self (``active=0, compacted=1``: still searchable, like the originals ``archive_and_compact`` keeps), then takes the replacement's changed columns under its own id. Unchanged rows, model order, row ids and concurrently appended rows are untouched; the FTS and display-identity triggers keep both indexes consistent; the counters are unchanged because no row enters or leaves the live set. Raises :class:`PruneRowUnresolvedError` before writing anything when a row cannot be named exactly (a merged dict, zero or several matches, an inactive row or a user row), so the caller can commit through ``archive_and_compact``. A named row whose stored payload moved on raises the :class:`PruneRowStaleError` subclass instead: that is another writer's generation, not ambiguity, and the full writer must not be handed the stale transcript. The staleness check is the repo's row-version CAS (``DB_ROW_SNAPSHOT`` / ``transcript_row_snapshot``, see ``agent/transcript_repair``) when the held dict carries the digest — it covers every owned column including assistant ``tool_calls`` arguments — and the representation-safe loader-lens identity compare otherwise (raw storage bytes are never compared against a loaded/normalized view; #124102). Returns the rows rewritten. Each rewritten dict is stamped with its row's new digest, so a second prune of the same transcript compares against what this commit wrote, not what it replaced. )ABSORBED_ROW_IDSrr2)PruneRowStaleErrorPruneRowUnresolvedErrorc V^8dQhRRRR/#)rrHrrz list[Any]r )r!s"rr"BSessionPruneRewriteMixin.rewrite_pruned_rows..__annotate__s z z# z) zr$c\V4;'g.Uu.uF,p\V\4'dVPR4MRNK. up#uupi)rBN)r r;rNr:)rHcalls& r _call_ids?SessionPruneRewriteMixin.rewrite_pruned_rows.._call_idssGTefpTqTwTwuwTwyTw4jt&<&SessionPruneRewriteMixin.rewrite_pruned_rows.._resolves<<'D00HLLAQ4R4R-4&8Z.[\\\\),F&#&&z&$/G/GFUVJhHLL$@$@15x.!9:2<1513=-2AAI2Lw2L#OXY\]iYjOkouOu&s3t9~2Lw//j(K3x1}-S :TUYTZZb.cdd,,WZ]^_Z`blYmoowowoy {c&kT1(4Ax7STXSYYa)bcc||O4H(C((+3/8;,tCF8;WX\W]]e-fgg<J$$T<< +BHLLQ_D`%6x||L7Q%RT))#f+t7K7KCPYN7[+.~+>@QRUVbRc@dff )4Ax7STXSYYa)bccJ;H wsL L&Lc p<S RJpV'dS!PVS"S RR7MRp.pSEFgwrES!W4pVR,VR,rVPR4V8wd S!R4hS!PS"Wt\VPR44WR8HR7p S!PS"Wu\VPR44WR8HR7p \ \ W4U U U u.uFwrp W8wgKV \ 9gKV NK pp p p V'gKTP\VR ,4T\ \ V 4U Uu.uFwrW9gK VNK upp VR ,VR ,e\VR ,4M\VR ,4V34EKj R PR S!PV444pVEF;wppppppVPRV RV R2V34PpVe$VPRS"VV34P4MVV3.pVPRR PRV44 R2.VOVN4TPRVUUu.uFwppTVfTMTV3NK upp4VPRV34P4pVPRS!P!S!P#V44VV34VPRV34P4pS#!V4VS&EK> V'dVPRVS"34\%V4#uup p p iuupp iuuppi)Nraise) on_missingrA timestampz,a prune replacement changed the message rolerHrJ)keep_reasoningrBdisplay_identity display_orderz, c38"TFpVR9gK VxK R#5i)rBN)rBrD compactedrr )rcs& rrLSessionPruneRewriteMixin.rewrite_pruned_rows.._do..s#%a0P1()1_(_&'Q0Ps  zINSERT INTO messages (z, active, compacted) SELECT z!, 0, 1 FROM messages WHERE id = ?zSELECT id, display_order FROM messages WHERE session_id = ? AND id <> ? AND display_identity = ? AND (active = 1 OR compacted = 1)zUPDATE messages SET c3*"TF q R2xK R#5i)z = ?Nr rs& rrrs=d\cRXo\csz WHERE id = ?zHUPDATE messages SET display_identity = ?, display_order = ? WHERE id = ?zSELECT role, content, timestamp, tool_call_id, tool_calls, tool_name, display_kind, display_metadata FROM messages WHERE id = ?z#SELECT * FROM messages WHERE id = ?z1UPDATE sessions SET model_config = ? WHERE id = ?)_merge_model_config_jsonr:_message_row_paramsr zip_MESSAGE_ROW_COLUMNS_PRUNE_FIXED_COLUMNSrTr<join_message_column_namesrP lastrowidrQ executemanyrS_display_identity_display_dedupe_keyrv)$r(patchpatched_model_configupdatesrs replacementr^rAr~beforeafterroldnewchangedvalue twin_columnsrXcolumnsvaluesidentityordertwin_idpeerspeer_id peer_orderlive final_rowrrkryrgrer)rr3s$& r_do9SessionPruneRewriteMixin.rewrite_pruned_rows.._dos&d2EMR$(#@#@j"4$A$JX\ !HJG)0%t."%f+s;/?i??6*d212`aa11*dN_LL.O01:S^K^2`00TPaOOL1Q34=VaNa1c:=>RTZ:bQ:b&6f3!j"-3;O-O"6:bQ7NNCD NG367KU3S>j3S-&W]Wh3S>j./585I5UC01[^_bcg_h[i# $%&*1" 99%a0J0J40P%aaLIPE5+,,)? ~N''3n4U(WY_XacclclCKBV Q245=HJ^egl]m\n 3DII=d\c=d4d3eers.v.v.0   !k=B"D=B&9gz$,j6HUjZa"b=B"DE||BDJ9NNVhj g"44T5M5Md5STV[]cdf !LL9F9FFNhj/Fy/Q O,7JQ8 PSgisRtuw< QQ>j,"Ds$ L% *L% 7L% ; L, L,L2) &agent.conversation_compression_archiverirLrrMr3hermes_state_errorsrjrk_ensure_display_order_execute_transcript_write)r)rrgrer_rrirrjrkrpryr3sfffd @@@@@@@rrewrite_pruned_rows,SessionPruneRewriteMixin.rewrite_pruned_rowssm8 L:CS z% % N6 6 n "":.-- G >7;F>F>r$rN>rArDr~rrGr)r __future__rtypingrragent.context_compressorrrOrLrhermes_state_commonrr hermes_state_messagesr r tuplesplitr frozensetrrr r$rrs# U29Huc!4!:!:3!B1!E!K!KCQR!STU!V!\!\]`!acuuc!4!:!:3!B1!E!K!KCQR!STU!V!\!\]`!acc!!rsq>q>r$