+ Wj Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t H t H t H t ^RI HtHtHtHtHtHtHtHtHt]P0!R4tRtR]!RR 4 R ]!RR 4 R ]P6!R R7 R]!R 4 R2 tRtRRltRRltRt R*t!RRlt"]#!0R+m4t$Rt%Rt&R]%P7RR7,R,t'RR lt(R!]%P7R"R7 R#]%P7R$R7 R%]!R&R'4 2t)!R(R)4t*R#),zCompression lineage, cooldown/streak counters, locks and turn leases for SessionDB. Mixin bound onto ``SessionDB`` via the MRO, built on its ``_read_ctx`` / ``_execute_write`` / ``_write_sql`` / ``_read_one`` primitives.) annotationsN)AnyDictListOptionalTuple) _BOUNDARY_END_REASONS_COMPRESSION_LOCK_ROW_SQL_ENDED_ROW_SQL_ended_by_compression_RESET_CHILD_SQL_non_continuation_child_sql_sql_json_extract_sql_session_last_activeis_automatic_end_reason hermes_statez_SELECT compression_failure_cooldown_until, compression_failure_error FROM sessions WHERE id = ?a SELECT child.id FROM sessions parent JOIN sessions child ON child.parent_session_id = parent.id WHERE parent.id = ? AND parent.end_reason = 'compression' AND zchild.model_configz$._branched_fromz# IS NULL AND z$._delegate_fromz( IS NULL AND NOT (child)aaI) AND COALESCE(child.source, '') != 'tool' ORDER BY CASE WHEN child.end_reason = 'compression' THEN 0 WHEN child.ended_at IS NULL THEN 1 ELSE 2 END, z DESC, child.started_at DESC, child.id DESC LIMIT 1 g@c V^8dQhRRRR/#)existsboolreturndict[str, Any])formats"LC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_state_compression.py __annotate__r9smm$m.mc6RTRVe\V4RV/#RRV/#)session_existscooldown_untilNerrorfloat)rr!r"s&&&r _cooldown_rowr%9s= f ~7QeN3]dfk mmW[]dfk mmrc4V^8dQhRRRRRRRRRRRRR R /#) rtablestrkey_colkeyholdernowr$ expires_atrztuple[bool, Optional[str]]r)rs"rrr>sIMM#MM#MsMQVMdiM9MrcRpVPRV RV R2V34P4p V eHV!V R,V R,4'd+VPRV RV R2W9R,34V R,pVPR V R V R 2W4WV34VPR V RV R2V34P4p V RJ;'d V R,V8HV3#) zSingle-transaction lease claim: DELETE a stale holder's row (``stale(holder, expires_at)``), INSERT OR IGNORE ours, then SELECT to confirm ownership (INSERT OR IGNORE gives no rowcount signal). Returns ``(acquired, reclaimed_holder)``.NzSELECT holder, expires_at FROM z WHERE z = ?r+r-z DELETE FROM z = ? AND holder = ?zINSERT OR IGNORE INTO z (z6, holder, acquired_at, expires_at) VALUES (?, ?, ?, ?)zSELECT holder FROM )executefetchone) connr'r)r*r+r,r-stalereclaimed_holderrowowners &&&&&&&& r_claim_lease_rowr6>s  ,,8wwitTWZV\ ] f f hC 5XL0ABB |E7'':MNQTZbVcPdex=LL r'2hi c&( LL.ugWWITJSF S \ \ ^E   : :xF!:r=_CHAIN_STEP_SQL) r1r9r4surfacerB parent_idrEparentrAs && rstamp_compression_ancestorsrVs ,,'* 7 @ @ BC'*c"#G(( ||'*z)JKTTV^#)<%=Y : VVt||,R?ltR@RAltRrRBRClltRrRDRElltRFRGltRHRIlt RJRKlt!RLRRR/RMRNllt"RLRRORPRQRRRSRRTRURVRRWRXRYR/RZR[llt#R\R]lt$RLRRR/R^R_llt%R`Ralt&RbRclt'RdRelt(RfRglt)RhRilt*RjRklt+RlRmlt,RnRolt-Rpt.R#)sSessionCompressionMixinzECompression lineage, cooldown/streak counters, locks and turn leases. patience_sNc(V^8dQhRRRRRRRR/#)rr9r( provenancerZOptional[float]r Optional[str]r)rs"rr$SessionCompressionMixin.__annotate__s,))).1)?N) )rc aaS'gR#VV3RlpSPWCR7pVe\PRSWR4V#)aClear an explicit-close stamp (``tui_close``, ``cli_close``, ``webhook_complete``, ...) from a session a HOST has just proven is still routed to it, returning the reason cleared or None (#106459). Narrow twin of ``reopen_session()``: automatic stamps are left to publish (#88197); ``compression``, boundary (reset reasons, CLI ``new_session``) and stamps with a published continuation own lineage elsewhere and are never touched. The UPDATE is conditional on the exact stamp read, so a close landing between read and write survives. Only the routing host can make this call. Publication cannot: ``end_session()`` is first-stamp-wins, so a close made during a turn that began on a stale stamp is a no-op write. Turn-lease admission cannot: the TUI starts its worker before it reaches ``run_conversation()``, so ``session.close`` can stamp ``tui_close`` in between and a late lease would clear a deliberate close. Call it under the lock that makes the host's registry claim atomic with its teardown (#54878 on the routing table).Nc<VP\S34P4pVe VR,fR#VR,p\V4'gVR8Xg V\9dR#VPRSP P RR7,R,S3^,4P4pVeR#VPRSVR,V34\V4#) Nended_at end_reason compressionz2SELECT 1 FROM sessions WHERE parent_session_id = ?aliasz LIMIT 1zgUPDATE sessions SET ended_at = NULL, end_reason = NULL WHERE id = ? AND ended_at = ? AND end_reason = ?)r/r r0rr"_NON_CONTINUATION_CHILD_FILTER_SQLrr()r1r4reason supersededselfr9s& r_do@SessionCompressionMixin.reopen_if_explicitly_closed.._dos,,~ }=FFHC{c*o5&F&v..&M2IVWlMlD99@@r@JKMWX !#$,8: % LLCS_f5 7v; rrZzSession %s carried a stale %r end stamp while %s; cleared so the conversation can compress and a later close is recorded (#106459))_execute_writeloggerwarning)rkr9r\rZrlrisff$$ rreopen_if_explicitly_closed3SessionCompressionMixin.reopen_if_explicitly_closedsK $$$S$@   NNCDNPV d rcV^8dQhRR/#rrintr)rs"rrr_s ( ( (rc *RpVPV4#)aStamp the unset ancestors of chains compressed before write-time stamping from their stamped segments, through ``stamp_compression_ancestors`` (same edge checks; a known value is never replaced). One write transaction and idempotent, so the owner runs it on every start: a store with nothing to repair pays one scan of sessions under the write lock, plus a one-hop walk per stamped child of an unset compression parent that the walk does not follow (a non-preferred sibling). Returns the rows stamped.cVPpVP\4P4Fp\ WR,4K VPV, #)r;) total_changesr/_UNSTAMPED_EDGE_CHILD_SQLfetchallrV)r1beforer4s& rrlDSessionCompressionMixin.stamp_legacy_compression_chains.._dosH''F||$=>GGI+Dd)<J%%. .rro)rkrls& rstamp_legacy_compression_chains7SessionCompressionMixin.stamp_legacy_compression_chainss / ""3''rc V^8dQhRRRR/#)rrNr(rOptional[dict[str, Any]]r)rs"rrr_sKKSKE]Krc  V'gR#VP4;_uu_4p\VP\V34P 44'g RRR4R#VPRVP P RR7,R,V3^,4P4pRRR4\X4^8XdVPV^,4#R# +'giL:;i)zThe unique live direct child of a compression-ended session, else None. A stale agent whose parent was rotated elsewhere may recover only when the lineage names exactly one live continuation; more than one fails closed.Nad SELECT s.*, COALESCE(sp.prompt, s.system_prompt) AS _system_prompt_resolved FROM sessions s LEFT JOIN system_prompts sp ON sp.hash = s.system_prompt_hash WHERE s.parent_session_id = ? AND s.ended_at IS NULL zs.rfzS ORDER BY s.started_at ASC LIMIT 2 ) _read_ctxr r/r r0rhrr{len_session_row_dict)rkrNr1rowss&& rfind_live_compression_child3SessionCompressionMixin.find_live_compression_childs! ^^  (nGXFZ)[)d)d)fgg <<99@@t@L M #$q( hj! (36d)q.t%%d1g.JdJ) s6C%#AC%% C5 c V^8dQhRRRR/#)rr9r(rrr)rs"rrr_ s7.7.c7.d7.rc \aaS'gR#VV3Rlp\SPV44#)zReopen a compression parent only when no continuation was published (older builds could leave a closed parent after an interrupted handoff). Conservative: an active lease or any canonical child means another path owns the lineage.Fcx<\VP\S34P44'gR#VPRSPP RR7,R,S3^,4P4pVeR#\ P !4pVP\S34P4pVeOVR,pVe\V4V8dR#VPRSVR,V34pVP^8wdR#VPRS34pVP^8H#) Fzt SELECT 1 FROM sessions WHERE parent_session_id = ? rerfz) LIMIT 1 r-zTDELETE FROM compression_locks WHERE session_id = ? AND holder = ? AND expires_at = ?r+z{UPDATE sessions SET ended_at = NULL, end_reason = NULL WHERE id = ? AND ended_at IS NOT NULL AND end_reason = 'compression') r r/r r0rhrtime _LOCK_ROW_SQLr$rowcount) r1rr,lock_rowr-deletedupdatedrkr9s & rrlHSessionCompressionMixin.reopen_orphaned_compression_session.._dos3(nzm)T)])])_``LL 99@@r@J K   ! hj  ))+C||MJ=AJJLH#%l3 %z):c)A ,,j(!3Z@B##q( llW  G ##q( (r)rrorkr9rlsff r#reopen_orphaned_compression_session;SessionCompressionMixin.reopen_orphaned_compression_session s)0 )bD'',--rcV^8dQhRR/#)rrrKr)rs"rrr_Ds- - ]a- rc a^RIHp V !VR,4P4U U u/uFwrV \9gKWbK pp p /VCS;'g/CoVP W4p\ ;QJdV3RlR4F 'gK RM RM!V3RlR44'*p^RIHpV!VR,4;'g V!V4pTPRYETTS'd\P!S4MR YR ,Y9;'g VR ,VR ,VR ,T ;'g"VR,;'gVP4VR,VR,VR,VR,VR,VR,VR,V'd\VR,;'g^4M^\P!4V'dVR,;'g^M^V'dVR,;'g^M^34R #uup p i)a INSERT the compression child's ``sessions`` row copied from *parent*. Same contract as _insert_session_row's compression-fork backfill: the child stays on the parent's profile and keeps gateway routing/origin columns; no owner on either side -> this store's profile.)_parse_model_config model_configc3@<"TFqS;'g/9xK R#5iNr).0krs& r ESessionCompressionMixin._publish_child_session_row..PsdBcQ\%7%7R8Bcs  TF)created_surfacerMa INSERT INTO sessions ( id, source, created_source, model, model_config, system_prompt, system_prompt_hash, tool_names, parent_session_id, cwd, git_branch, git_repo_root, profile_name, user_id, session_key, chat_id, chat_type, thread_id, display_name, origin_json, pinned, started_at, archived, auto_archived ) VALUES (?, ?, ?, ?, ?, NULL, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)N tool_namescwd git_branch git_repo_root profile_nameuser_id session_keychat_id chat_type thread_id display_name origin_jsonpinnedarchived auto_archived)_branched_from _reset_from)hermes_state_sessionsritems_CONVERSATION_MODEL_CONFIG_KEYS_store_system_promptanygateway.session_policyrr/jsondumps_own_profile_namervr)rkr1rUrNchild_session_idsourcemodelr system_promptrrrr*valuecarriedsystem_prompt_hash continuationrrMs&&&$$$$d$$$ r_publish_child_session_row2SessionCompressionMixin._publish_child_session_rowDs >0CF>DZ0[0a0a0c>0c*#<<3:0c>:':l&8&8b: !66tK3dBcd333dBcddd  ;(0@)AB]]oV\F]  h!.%]iLAYos"<$8:KMaMaTZ[`Tacijvcw'RR~ 6RR$:P:P:Ry!6-#8&:KVT_M`{#VN%;VM=R.:F8$))*499;.: #((qq2>(--AA G #>s G=G=rrrrrcompression_lock_holderrequire_compression_leaseTrequire_lease_refreshFlease_ttl_secondsr@ watermarkwatermark_ceilingc XV^8dQhRRRRRRRRRRR R R RR RR RRRRRRRRRRRRRRR/#rrNr(rrmessageszlist[dict[str, Any]]rz str | Nonerzdict[str, Any] | Nonerrrrrrrrr$r Optional[int]rrrKr)rs"rrr_ssvv$'v;>vHKv&v/9vPev"v0:vQ[v", vPT v $ v AF v ! v =J v VZ vrc paaaaaaaaaa a a a a aaSPVV VV VVVVV V V VVVVV3RlS4R#)u6Atomically close a parent and publish its durable compression child: closure, child row, and handoff commit in one transaction, so readers see the live parent or a complete child, never an ended parent with a missing/empty child. *watermark* (the parent's highest row already represented in the handoff: its ``get_active_message_watermark`` at compression start, or the newest row of an adopted durable snapshot): parent rows with ``id > watermark`` — appends landed during the slow summary — are column-cloned into the child AFTER the handoff. *watermark_ceiling* bounds the clone: the rotation path flushes its OWN transcript to the parent just before publishing and those rows are already in the handoff, so only ``(watermark, watermark_ceiling]`` is foreign tail (``None`` = unbounded). *require_lease_refresh* + *compression_lock_holder* refreshes the lease on the same ``conn`` before the expiry check (no TOCTOU window), so a refresher that died on transient DB errors gets one last chance. See #75316. ``None`` = unbounded (no internal flush happened). See #47202. cF<S PVSSS SSSSSS SS S SSSR7#))rNrrrrrrrrrrrrrr)"_publish_compression_child_on_conn)r1rrrrrrrrNrrrrkrrrrs&rCSessionCompressionMixin.publish_compression_child..sCD4[4[ $5HXagUUb,H_&?Wl/9Xi 5\5krN)_execute_transcript_write)rkrNrrrrrrrrrrrrrrsfdddddddddddddddrpublish_compression_child1SessionCompressionMixin.publish_compression_childss., &&(k(k(k mu  vrc XV^8dQhRRRRRRRRRRR R R RR RR RRRRRRRRRRRRRRR/#rr)rs"rrr_sRJRJ.1RJEHRJRURJ*RJ3=RJTiRJ&RJ4>RJU_RJ&0 RJTX RJ $( RJ EJ RJ % RJ AN RJ Z^ RJrc  L^RIHpV 'd7V 'd/VPR\P!4V,W+34VP\V34P 4pV 'dPVeAV 'd9VR,V 8wg+\ VR,4\P!48:d V!RV 24hVPRV34P 4pVf\RV 24hVR ,e:\VR ,4'g\R V 24hVPR V34V'g \R 4hVPVVW#WFWxWR7 VPWV4VPWV4wppVeVRJpTPTRV'dRMR R2V\V4.V'd \V4.M.O4wppV'd0VPVVVR7V\V4, pVV, pVPRVVV34VPR\P!4V34pVP ^8wd\RV 24h\#W4^RIHpV!WV4VR,'dVP)W4R#R#)z:meth:`publish_compression_child` on the caller's write transaction (never commits). The owner and the worker/canonical-mutation verbs share this one body so they cannot drift.)CompressionSessionBusyErrorOUPDATE compression_locks SET expires_at = ? WHERE session_id = ? AND holder = ?Nr+r-z+Compression lease lost before publication: aPSELECT ended_at, end_reason, cwd, git_branch, git_repo_root, user_id, session_key, chat_id, chat_type, thread_id, display_name, origin_json, profile_name, tool_names, archived, auto_archived, pinned, model_config, created_source FROM sessions WHERE id = ?zCompression parent not found: rbrcz"Compression parent already ended: zCUPDATE sessions SET ended_at = NULL, end_reason = NULL WHERE id = ?z+Compression child handoff must not be empty)rNrrrrrrrzRSELECT id, tool_calls FROM messages WHERE session_id = ? AND active = 1 AND id > ?z AND id <= ?rez ORDER BY id)r9zGUPDATE sessions SET message_count = ?, tool_call_count = ? WHERE id = ?z^UPDATE sessions SET ended_at = ?, end_reason = 'compression' WHERE id = ? AND ended_at IS NULLz/Compression parent changed during publication: )advance_local_targetr)hermes_state_errorsrr/rrr0r$ RuntimeErrorrr_carry_parent_timestamps_insert_message_rows_tail_rows_after_watermarkrv_clone_message_rowsrrrVhermes_state_local_lineager _unarchive_auto_archived_lineage)rkr1rNrrrrrrrrrrrrrrrrrUtotal_messagestotal_tool_callsboundedtail_idstail_tool_callsrrs&&$$$$$$$$$$$$$$$ rr:SessionCompressionMixin._publish_compression_child_on_conns D %< LLa002C] _<< 0A/CDMMO $  $;!%<<Xl+, ;-=>O=PQS S -    (*  >!?@Q?RST T *  ) +6,+?@@"%GHYGZ#[\\ LLU"$ &LM M '' &,=\ ( 0 %%dxH+/+D+DT]e+f((  (t3G(,(G(GA%,>"5\C#C NcRYs;L7M6N_ac )e %Ho ((xDT(U#h-/ O3  U -/? @ B,, 026))+?P1QS   q !PQbPcde e $D;CT6FG *    1 1$ I rc(V^8dQhRRRRRRRR/#)ropr(r9sqlrrKr)rs"rrr_s.EECESEsEtErc VPW44R# \Pd#p\P RYT4Rp?R#Rp?ii;i)z=``_write_sql`` that logs (never raises) on ``sqlite3.Error``.z%s(%s) failed: %sN) _write_sqlsqlite3Errorrprq)rkrr9rparamsexcs&&&&& r_write_sql_logged)SessionCompressionMixin._write_sql_loggeds> E OOC (}} E NN. D D EsA AA c(V^8dQhRRRRRRRR/#) rr9r(r!r$r"r^rrKr)rs"rrr_s2 A A A/4 A=J AVZ Arc  FV'gR#VPRVRW"W134R#)zPersist the active compression-failure cooldown. Merge-max with any longer live deadline so a later shorter write can't reopen the thrash window; error always takes the latest diagnostic.N#record_compression_failure_cooldownzUPDATE sessions SET compression_failure_cooldown_until = CASE WHEN compression_failure_cooldown_until IS NOT NULL AND compression_failure_cooldown_until > ? THEN compression_failure_cooldown_until ELSE ? END, compression_failure_error = ? WHERE id = ?r)rkr9r!r"s&&&&rr;SessionCompressionMixin.record_compression_failure_cooldowns.   1: mU ? Arc V^8dQhRRRR/#)rr9r(rrr)rs"rrr_sll3lC[lrc *\P!4pV'dVP\V34MRpVe#V^,e\V^,4V8:dR#R\V^,4R\V^,4V, RV^,/#)zDReturn the active (unexpired) compression-failure cooldown, or None.Nr!remaining_secondsr")r _read_one_COOLDOWN_ROW_SQLr$)rkr9r,r4s&& r get_compression_failure_cooldown8SessionCompressionMixin.get_compression_failure_cooldownswiikBLdnn. >RV ;#a&.E#a&MS,@ %A-1DeCPQFmVYFY[bdghidjkkrc V^8dQhRRRR/#)rr9r(rrr)rs"rrr_shhsh~hrc V'dVP\V34MRpVf\RRR4#\RV^,V^,4#)zExact stored cooldown columns, no expiry filtering, so compression cancellation can roll back an expired, partially-null, or absent row exactly.NFT)rrr%rkr9r4s&& r$get_compression_failure_cooldown_rowRV36;}UD$/gMRVX[\]X^`cde`fDggrc$V^8dQhRRRRRR/#)rr9r(snapshotrrrKr)rs"rrr_s(pp3pR`peiprc $aaaVPRR4'g5VPS4PRR4'd \R4hR#VPR4oVPR4oVVV3RlpVPV4'g\P RS4R#VPS4p\ R SS4pWE8wdDVPRR4'g\P R S4R#\R V: R V: 24hR#) uRestore and verify an exact cooldown-row snapshot. Unlike record/clear this rollback API propagates write and verification failures: cancellation must not be reported mutation-free when compensation failed. The tolerated exception is a session row that vanished mid-attempt — before or after the compensating write — since its cooldown died with it and there is nothing left to restore (#106271).r FzBcannot restore absent compression cooldown row: session now existsNr!r"cL<VPRSSS34pVP^8H#)zfUPDATE sessions SET compression_failure_cooldown_until = ?, compression_failure_error = ? WHERE id = ?)r/r)r1cursordeadliner"r9s& rrlMSessionCompressionMixin.restore_compression_failure_cooldown_row.._dos3\\=?GPZ>[]F??a' 'rz1compression cooldown rollback session missing: %sTz?compression cooldown rollback session missing after restore: %szH] Lrc ,V^8dQhRRRRRRRRRR/#) rcolumnr(r9casttypezerorrr)rs"rrr_.s13CtSV[^rc V'dVPRV R2V34MRpVfV#\YC!V^,;'gT44# \\3dTu#i;i)z~Read one numeric ``sessions`` column clamped at ``zero``; a missing session, NULL, or unparsable value also reads as ``zero``.zSELECT z FROM sessions WHERE id = ?N)rmax TypeError ValueError)rkrr9rrr4s&&&&& r_read_session_number,SessionCompressionMixin._read_session_number.sj_idnnwvh.IJZMZnr ;4 KCd3q6>>T6J,K K:& K sA A A A! A!c(V^8dQhRRRRRRRR/#)rrr(r9rrrrKr)rs"rrr_7s/__C_S__QU_rc 4VPRV R2W234R#)zUPDATE sessions SET z = ? WHERE id = ?N)r)rkrr9rs&&&&r_write_session_column-SessionCompressionMixin._write_session_column7s .vh6GH5J]^rc V^8dQhRRRR/#rr9r(rrvr)rs"rrr_:\\#\#\rc 2VPRV\^4#)z3Return the persisted deterministic-fallback streak.compression_fallback_streakr"rvrs&&rget_compression_fallback_streak7SessionCompressionMixin.get_compression_fallback_streak:(()F TWYZ[[rc$V^8dQhRRRRRR/#rr9r(streakrvrrKr)rs"rrr_>&gg#gsgtgrc  fV'd)VPRV\^\V444R#R#)z:Persist the deterministic-fallback streak for one session.r,Nr&rrvrkr9r3s&&&rset_compression_fallback_streak7SessionCompressionMixin.set_compression_fallback_streak>-   & &'DjRUVWY\]cYdRe f rc V^8dQhRRRR/#r)r)rs"rrr_Cs^^C^C^rc 2VPRV\^4#)uPersisted ineffective-compaction strike count — the durable half of the built-in compressor's anti-thrash guard, so a fresh compressor bound to a resumed session inherits an armed/tripped guard across restarts.compression_ineffective_countr-rs&&r!get_compression_ineffective_count9SessionCompressionMixin.get_compression_ineffective_countCs(()H*VY[\]]rc$V^8dQhRRRRRR/#)rr9r(countrvrrKr)rs"rrr_Is'hhChhPThrc  fV'd)VPRV\^\V444R#R#)z@Persist the ineffective-compaction strike count for one session.r=Nr6)rkr9rAs&&&r!set_compression_ineffective_count9SessionCompressionMixin.set_compression_ineffective_countIs-   & &'F TWXY[^_d[eTf g rc V^8dQhRRRR/#)rr9r(rr$r)rs"rrr_NsbbCbEbrc 2VPRV\R4#)aPersisted anti-thrash recovery deadline (epoch; ``0.0`` = not armed). Durable because the gateway rebuilds the compressor every turn / cache eviction. The deadline is the durable half of the 14694 recovery clock: the gateway rebuilds the compressor on every turn / cache eviction, so a process-local deadline restarted the wait on each rebuild and a tripped session never earned its probe (#100185). compression_recovery_deadline)r"r$rs&&r!get_compression_recovery_deadline9SessionCompressionMixin.get_compression_recovery_deadlineNs(()H*V[]`aarc$V^8dQhRRRRRR/#)rr9r(r r$rrKr)rs"rrr_Xs'ddCd5dUYdrc V'gR#\R\T;'gR44pTP RY;'gR4R# \\3dRpL3i;i)zGPersist the anti-thrash recovery deadline; ``0`` / ``None`` disarms it.NrHrG)rr$r r!r&)rkr9r  normalizeds&&& r!set_compression_recovery_deadline9SessionCompressionMixin.set_compression_recovery_deadlineXs[  S%C"89J ""#BJPbPb^bc:& J sA A AAc V^8dQhRRRR/#r)r)rs"rrr_br*rc 2VPRV\^4#)z?Return the persisted sustained-overload abort streak (#123167).compression_overload_streakr-rs&&rget_compression_overload_streak7SessionCompressionMixin.get_compression_overload_streakbr0rc$V^8dQhRRRRRR/#r2r)rs"rrr_fr4rc  fV'd)VPRV\^\V444R#R#)z._dopsB,,FHR}VV^V^V` ;4 7CAK 7rr~rs&f r%increment_compression_overload_streak=SessionCompressionMixin.increment_compression_overload_streakks# 8 ""3''rc(V^8dQhRRRRRRRR/#rr9r(r+ ttl_secondsr$rrr)rs"rrr_ws*3RWdhrc V'd V'gR#\P!4V,pVPRWAV34^8# \Pd"p\P RY4Rp?R#Rp?ii;i)uExtend the compression lock lease if ``holder`` still owns it. Ownership is decided by ``holder`` alone, deliberately NOT ``expires_at``: a live owner whose refresher stalled past its TTL must be able to revive its still-unclaimed row, otherwise it keeps compressing with no lease — the window in which a competing path can fork the lineage. It cannot resurrect a lock someone else took: SQLite serialises writes, so the reclaim (DELETE-expired + INSERT OR IGNORE) never interleaves with this UPDATE.Frz'refresh_compression_lock(%s) failed: %sN)r_write_rowcountrrrprq)rkr9r+rar-rs&&&& rrefresh_compression_lock0SessionCompressionMixin.refresh_compression_lockwsoYY[;.  ''a02456 6}}  NNDj V sAA=A88A=c(V^8dQhRRRRRRRR/#r`r)rs"rrr_s*sCV[hlrc laaaa a ^RIHoS'gR#\P!4o S V,o VV VV V3RlpVPV4wrVV'd\P RSV4\ V4# \Pd#p\P RST4Rp?R#Rp?ii;i)aTry to atomically acquire the compression lock for ``session_id``. ``False``: another holder owns a live lock and the caller MUST NOT compress (its rotation would split the lineage). Expired locks and structured holders whose local ``pid=`` is dead are reclaimed transparently.(_compression_lock_holder_process_is_deadFc 2<\VRRSSSSVV3Rl4#)compression_locksr9c.<VS8;'g S!V4#rrherir,s&&rrSSessionCompressionMixin.try_acquire_compression_lock.._do..sQWSS(PQR(SSr)r6)r1rir-r+r,r9s&rrlASessionCompressionMixin.try_acquire_compression_lock.._dos&#)<VSR\SU Urz;Reclaimed stale compression lock for session=%s (holder=%s)z+try_acquire_compression_lock(%s) failed: %sN) rrirrorprqrrr) rkr9r+rarlacquiredr3rrir-r,s &ff& @@@rtry_acquire_compression_lock4SessionCompressionMixin.try_acquire_compression_locks Jiik;&  U U )-)<) !}}  NNH*VY Z s.__annotate__s . .c .rcp<SPRV34P4pV'd \V4#R#)zYSELECT id, parent_session_id, source, model_config, end_reason FROM sessions WHERE id = ?N)r/r0dict)r~r4r1s& r_rowESessionCompressionMixin._session_turn_lease_key_on_conn.._rows6,,k   !$49 - -rrNT include_resetrcrdr;)r_is_explicit_fork_child_rowr?r()rkr1r9rrBrDrTrUs&f& r_session_turn_lease_key_on_conn7SessionCompressionMixin._session_turn_lease_key_on_conns   . . z"| $78I 1T5U5UV]mq5U5r5r)_FVZZ 5F HHY G7>s7;;t$22 3NJNrc V^8dQhRRRR/#r{r)rs"rrr_sJJ#J#Jrc V'gV#VP4;_uu_4pVPW!4uuRRR4# +'giR#;i)zStable serialization key for every compression segment (tests/diagnostics; the write paths resolve it inside their own txn). Does not swallow lock errors.N)rr)rkr9r1s&& r_session_turn_lease_key/SessionCompressionMixin._session_turn_lease_keys9  ^^  77I   s ? A rac ,V^8dQhRRRRRRRRRR /# rr9r(r+rar$rZr]rrr)rs"rrr_s;EEE'*E._do..sU1X_[[0XYZ0[[r)r/_TURN_LEASE_SWEEP_GRACE_Srr6)r1rrir-r+r,rkr9s& rrlCSessionCompressionMixin.try_acquire_session_turn_lease.._dos` LLO 99; ="BB4TO#+->QWY\^h[ rrn)rrirrr$rro) rkr9r+rarZrlrir-r,s fff$$ @@@rtry_acquire_session_turn_lease6SessionCompressionMixin.try_acquire_session_turn_leasesW Jiik3sE+$677   D'''CDDr wait_secondsg @poll_interval_secondsg?on_waitwait_notice_interval_secondsg.@ should_abortacquire_patience_sg? on_contendedc8V^8dQhRRRRRRRRRRRRR RR R /#) rr9r(r+rar$rrrrrrr)rs"rrr_s^<P<P<P'*<P>#c#u\/B&CC% 3&B CD 'c#~~$& 66K7VVV&*H.."C 3IA~#" "&,#*=#BV[gAg^CS<%789"% JJs3tU+@%ABIN OK!cLL!R]aLbc == .c2h>+g$$g %Vae fg1CUCX=Y4ZZ"#5$..BR7RSU55hDD  8!^LL!MX\L]^sa D!(E H!"EE HH1E98H9"FHFA$HH"H=<H=c$V^8dQhRRRRRR/#)rr9r(r+rr]r)rs"rrr_$s! . . .S ._ .rc  (V'd V'gR#VP4;_uu_4pVPRVPW14V34P4pRRR4X'd\ V^,4#R# +'giL,;i)zVCommitted ``expires_at`` of ``holder``'s turn lease, or None when it does not hold it.NzSSELECT expires_at FROM session_turn_leases WHERE conversation_id = ? AND holder = ?)rr/rr0r$)rkr9r+r1r4s&&& rsession_turn_lease_expires_at5SessionCompressionMixin.session_turn_lease_expires_at$sn ^^  ,,e55dGPhj  !$uSV}--  s 2B B c ,V^8dQhRRRRRRRRRR /#rr)rs"rrr_/s;EEE'*E._do7sD"BB4TO<<;=GZ`#??    D'''CDDrc$V^8dQhRRRRRR/#rvr)rs"rrr_?s! ! !S !# !$ !rc baaaS'd S'gR#VVV3RlpSPV4R#)z>Release a turn lease iff ``holder`` still owns it; idempotent.NcT<SPVS4pVPRVS34R#)zHDELETE FROM session_turn_leases WHERE conversation_id = ? AND holder = ?N)rr/)r1rr+rkr9s& rrl?SessionCompressionMixin.release_session_turn_lease.._doCs,"BB4TO LLZ &) +rr~)rkr9r+rlsfff rrelease_session_turn_lease2SessionCompressionMixin.release_session_turn_lease?s   + C rc V^8dQhRRRR/#rr9r(rr^r)rs"rrr_Js//c/m/rc V'gR#VPRV\P!434pVfR#V^,#)zJCurrent (non-expired) holder for ``session_id``, or None. Diagnostic only.NzMSELECT holder FROM compression_locks WHERE session_id = ? AND expires_at >= ?)rrrs&& rget_compression_lock_holder3SessionCompressionMixin.get_compression_lock_holderJs?nn [^hjnjsjsju]vx{t.A.rcV^8dQhRR/#rur)rs"rrr_Rsrc \P!4R, pVPR\P!4V34;'g^#)zMark orphaned compression continuations (parent ended by compression; child has messages, no end_reason/ended_at, api_call_count=0, older than 7 days) as ``orphaned_compression``. Non-destructive. Fix for #20001. i: a UPDATE sessions SET ended_at = ?, end_reason = 'orphaned_compression' WHERE api_call_count = 0 AND end_reason IS NULL AND ended_at IS NULL AND started_at < ? AND parent_session_id IS NOT NULL AND EXISTS ( SELECT 1 FROM sessions p WHERE p.id = sessions.parent_session_id AND p.end_reason = 'compression' AND p.ended_at IS NOT NULL ) AND EXISTS ( SELECT 1 FROM messages m WHERE m.session_id = sessions.id ) )rrc)rkcutoffs& r&finalize_orphaned_compression_sessions>SessionCompressionMixin.finalize_orphaned_compression_sessionsRsKv%##(f%+ ,- rc V^8dQhRRRR/#r8r)rs"rrr_rs 9 9 9 9rc ,aRV3Rllp\W4#)anWalk the compression-continuation chain forward: root-first through the tip (``[session_id]`` when no continuation); ``get_compression_tip`` is the last element. A continuation is a child of a session with ``end_reason='compression'``. The old ``child.started_at >= parent.ended_at`` test was too brittle (gateway + compression races insert the real continuation before ``ended_at`` is written, while a stale websocket later creates a sibling that passes it). Instead exclude branch/delegate/tool children and prefer children that continue the chain or are still live over stale closed siblings such as ``ws_orphan_reap``.cV^8dQhRR/#)rrBr(r)rs"rrCSessionCompressionMixin.get_compression_chain..__annotate__zs L L# Lrc<SP4;_uu_4pVP\V34P4uuRRR4# +'giR#;ir)rr/rRr0)rBr1rks& rrA;SessionCompressionMixin.get_compression_chain..stepzs:!!T||OgZ@IIK"!!!s %A  A rG)rkr9rAsf& rget_compression_chain-SessionCompressionMixin.get_compression_chainrs L L'z88rc V^8dQhRRRR/#rr)rs"rrr_s22c2m2rc JVPV4pV'd VR,#T#)zpLive tip of a compression chain (``get_compression_chain`` semantics); the input id when no continuation exists.)r)rkr9rCs&& rget_compression_tip+SessionCompressionMixin.get_compression_tips%**:6!uRy1z1rc V^8dQhRRRR/#r{r)rs"rrr_s}}C}C}rc 2a\VV3Rl4R,#)z``get_compression_tip`` read on a writer's own connection: inside its transaction no rotation can publish between finding the tip and writing it.cN<SP\V34P4#r)r/rRr0)rBr1s&rr=SessionCompressionMixin._compression_tip_on..s4<.s-fDSD&?@FVD\Y6D MM$t* %:,T |kk,'=8>>dm% 'D fDfhlmJD!1T!9 NN:d+ , HHZ% & G$/wAj\Arrr)r)/__name__ __module__ __qualname____firstlineno____doc__rrrrrrrrrrrrrrr"r&r.r8r>rCrIrNrSrWr]rdrsrxrrrrrrrrrrrrrr__static_attributes__rrrrYrYsO)QU)V (K87.r- ^v<@vhlv%)v=Av^bv/3 vW[ v ', v IN v $( v MQ v:RJ@DRJlpRJ)-RJAERJbfRJ37 RJ[_ RJ +0 RJ MR RJ (, RJ QU RJhE Alh p:L_\g ^ h bd\g ($2"O4JEDIEimE2<PDI<P$<PEH<PRV<P/3<PBF<Pdg<P <P| .EDIEimE !/@ 92 } JBBrrY)onboarding_run>Nrelocalunknown)+r __future__rrloggingrrtypingrrrrrhermes_state_commonrr rr r r r rrr getLoggerrprrrRrr%r6r>rrG frozensetrP_UNSET_CREATED_SQLrOrQrVrzrYrrrrsC #  33   > *f --ACUVWX,-ACUVWX 0 7 7' BCD089:!0$m M( #6,##ABFX/2D1J1JOa1J1bcf DL!11C1J1JOf1J1g0hi!((-C(DEFX{34 8} B} Br