+ jHjRt^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RI H t H t H t H t HtHtHtHt^RIHtHtHt^RIHt^RIHtHtHtHtHtHtHtH t H!t!H"t"H#t#H$t$H%t%H&t&H't(H)t)H*t*H+t,H-t-H.t.H/t/^RI0H1t1H2t2]Pf!R4t4R R lt5RER R llt6]7!4t8R t9RRlt:RRlt;RRltR%R&lt?R'R(lt@R)R*ltARGtBR+tCR,tDR-tER.tF]G!0RHm4tHR/R0ltIR1tJR2PR3RI44R2,R5]2P!R6R77,R8,,tMRFR9R:lltNRJtOR;]OP.R<RK4O]N!R4RLR=]J R>2,4N54,R?,tPRPR@RM44tQR;]OPRARN44,RB,]Q,tR!RCRD4tSR#)OzSession lifecycle mixin for SessionDB: row upsert/inheritance, lifecycle flags (end/reopen/archive/pin/hide/read), model_config patching, listing and counting, delete cascades, and the auto-archive sweep.N)Path)AnyCallableDictListOptionalSequenceTupleUnion)ActivityProvenancebound_activity_descriptionnormalize_activity_provenance)SessionActiveWriteGuardError)_LISTABLE_CHILD_SQL_RECOVERABLE_END_REASONS_RECOVERABLE_END_REASONS_SQL_RESET_CHILD_SQL_RESET_END_REASONS_legacy_reset_child_sql_non_continuation_child_sql_shape_preview_sql_preview_rawQUEUED_PROMPT_METADATA_KEY_sql_in_window_sql_json_extract_sql_session_last_active_sql_session_last_active_by_id escape_like _SQL_IN_CHUNK _id_chunks _placeholders_source_match_clauseemit_session_deletedlaunch_stub_filter_sql) _CHAIN_CAP_UNSET_CREATED_SQL hermes_statechV^8dQhR\\\3,R\\,/#rowreturn)dictstrrr)formats":/home/ubuntu/.hermes/hermes-agent/hermes_state_sessions.py __annotate__r0 s*^^tCH~^(3-^cVPR4;'gRP4;'g4VPR4;'gRP4;'gR#)zsWorkspace grouping key: git repo root, else cwd, else None (branch excluded: a checkout must not fragment history). git_repo_rootcwdN)getstrip)r*s&r/ workspace_keyr8 sN GGO $ * * 1 1 3 ] ]8L8L"7S7S7U ] ]Y]]r1c0V^8dQhR\R\/#)r)colr+r-)r.s"r/r0r0&s66S6c6r1c\VR4#)$._delegate_fromrr:s&r/_delegate_from_jsonr@&s S"4 55r1at WITH RECURSIVE ancestors(id) AS ( SELECT ? UNION SELECT parent.id FROM ancestors a JOIN sessions child ON child.id = a.id JOIN sessions parent ON parent.id = child.parent_session_id WHERE parent.end_reason = 'compression' ), descendants(id) AS ( SELECT ? UNION SELECT child.id FROM descendants d JOIN sessions parent ON parent.id = d.id JOIN sessions child ON child.parent_session_id = parent.id WHERE parent.end_reason = 'compression' ), lineage(id) AS ( SELECT id FROM ancestors UNION SELECT id FROM descendants )cRV^8dQhR\R\\\3,/#)r)rawr+)rr,r-)r.s"r/r0r0Ks"66S6T#s(^6r1c\V\4'd.VP4'd\P!V4p\V\4'd \V4#/# \P \ 3d/u#i;i)zVTolerant ``model_config`` decode: JSON text or dict -> dict copy; anything else -> {}.) isinstancer-r7jsonloadsJSONDecodeError TypeErrorr,)rBs&r/_parse_model_configrIKsi#s  **S/C#3--49525$$i0 I sA''BBchV^8dQhR\R\\\\,3,/#)r) cwd_prefixr+r-tuplelist)r.s"r/r0r0Us'35d3i+@r1cfVPR4;'gTp\V4pRW R2V R2.3#)/\zA(s.cwd = ? OR s.cwd LIKE ? ESCAPE '\' OR s.cwd LIKE ? ESCAPE '\')z/%z\\%)rstrip _escape_like)rKprefixescs& r/_cwd_prefix_clauserUUsG   u % 3 3F v CM 5uE]+ r1chV^8dQhR\R\\\\,3,/#r)keyr+rL)r.s"r/r0r0`s'suS$s)^'<r1chVPR4;'gTp\V4wr#RV R2V.VO3#)zWHERE for ``workspace_key(row) == key``: git_repo_root equals ``key``, or (rows predating per-session git metadata) cwd is at/under ``key``.rPz@(s.git_repo_root = ? OR (COALESCE(s.git_repo_root, '') = '' AND )))rQrU)rXrS cwd_clause cwd_paramss& r/_workspace_key_clauser]`sIZZ  % %#F/7J J:,VXY * r1r4cRV^8dQhR\\,R\R\/#)r)clausesleadr+rNr-)r.s"r/r0r0ks*EES EEcEr1cBV'dV RRPV4 2#R#)zG``WHERE a AND b`` (with *lead* prefix) or "" when there are no clauses.WHERE  AND r4)join)r_r`s&&r/ _where_sqlrfks$5= ?zs.archived = 1s.archived = 0)appendrr@rNr!_session_ids_placeholdersrUextend)rgrhrirjrkrKrlrmrnrorpwhereparamsinclude_sources source_clause source_paramsclausevaluess$$$$$$$$$$$ r/_session_filter_whererpsMEF- q,-T2EFV2W1XXefg  %*=>N*O)PPX'YZZ#)vhd7==b.AO#7#_ M & {{mC 67L7L"MNa PRaRgRgegh+5 J 'B8 8IA8M"3!4SUV  6 LL MM& ! %& = %& =r1c\V^8dQhR\\,R\\,/#)r)frontierr+ra)r.s"r/r0r0s"!!DI!$s)!r1c VUu.uFq"'gK VNK ppV'g.#.p\V\^,4Fp\V4p\RR4 R\RR4 R\P !RR7 R2pVP R VPR V R V 2V4P444VP R VPR V R V 2V4P444K V#uupi)uOne both-direction compression-edge step from *frontier*: forward through every continuation child and backward through the compression parent, using the SAME edge definition as ``_CHAIN_STEP_SQL`` / the list-projection CTE (parent ended with ``reason='compression'``, child is not a branch / reset / delegate / tool session). Branch/reset children are NOT continuations — they are their own conversations.child.model_config$._branched_from IS NULL AND r=z IS NULL AND NOT (childaz*) AND COALESCE(child.source, '') != 'tool'c32"TF qR,xK R#5iidNr|.0r*s& r/ 2_expand_compression_lineage_ids..s)t99)ztSELECT child.id FROM sessions parent JOIN sessions child ON child.parent_session_id = parent.id WHERE parent.id IN (z,) AND parent.end_reason = 'compression' AND c32"TF qR,xK R#5irr|rs& r/rrs)t99)rztSELECT parent.id FROM sessions child JOIN sessions parent ON parent.id = child.parent_session_id WHERE child.id IN () rrr~rrr.rexecutefetchall)connrsididsoutchunkph child_filters&& r/_expand_compression_lineage_idsrs= # *(3c33(C *  CC!!34 &u - !57IJKL$%9;MNOP(//':;<7 7   ##%$&RS_R` b  ) (* )   ""$&. "  )  (*) 5. J7 +s C>C>c\V^8dQhR\\,R\\,/#r) parent_idsr+ra)r.s"r/r0r0s"66$s)6S 6r1c $\4pVUu0uFq3'gK VkK pp\V4p\V4pV'd.p\V\^,4Fp\ V4p VP RV RV RV RV R2 W,4p V P4FCp V R,V9gKVPV R,4VPV R,4KE K TpKVUu.uF q3V9gK VNK up#uupiuupi)zDelegate-subagent ids (``_delegate_from`` marker, walked recursively) to cascade-delete with *parent_ids*; untagged children stay orphaned, not deleted.SELECT id FROM sessions WHERE z IN (z) OR (parent_session_id IN (z) AND rwr) r@setrNrrr~rraddr}) rrdfrseedsfoundr next_frontierrrcursorr*s && r/_collect_delegate_child_idsrs  B& .JS#SSJE .%jEE{H #% -1*<=E*51B\\0E">--/Drd-IJO-F(t9E)IIc$i(!((T3) >! 55Cu$4CC5 55/ /. 6s DD2D ?D c\V^8dQhR\\,R\\,/#rra)r.s"r/r0r0s"  S d3i r1c\W4p^RIHpV!W4\V4FPp\ V4pVP RV R2V4VP RV R2V4VP RV R2V4KR V#)retire_sessions*DELETE FROM messages WHERE session_id IN (rzIUPDATE sessions SET parent_session_id = NULL WHERE parent_session_id IN ("DELETE FROM sessions WHERE id IN ()r hermes_state_mutation_retirementrrr~r)rrrrrrs&& r/_delete_delegate_childrenrs %d 7C@DC &u - A"QGO `ac`ddefhmn 9"Q?G ! Jr1complete interruptederroremptyctV^8dQhR\\,R\R\\,R\/#)r)rolehas_tool_calls finish_reasonr+)rr-rr)r.s"r/r0r0s4##(3-##V^_bVc#hk#r1cT;'gRP4P4\9d\#T;'gRP4P4pVR9gVR8XdV'd\#\ #)uError finish → ``error``; assistant with pending tool_calls or a trailing user/tool row → ``interrupted``; otherwise ``complete`` (benign default: pickers must not alarm on unknown shapes).r4 assistant>tooluser)r7lower_ERROR_FINISH_REASONSSESSION_STATUS_ERRORSESSION_STATUS_INTERRUPTEDSESSION_STATUS_COMPLETE)rrrrs&&& r/classify_session_statusrsh ""$**,0EE## ""$A k!1n)) ""r1zp.session_key IS NULL OR sessions.session_key IS NULL OR substr(p.session_key, 1, instr(substr(p.session_key, 7), ':') + 6) = substr(sessions.session_key, 1, instr(substr(sessions.session_key, 7), ':') + 6), c#:"TFpRV RV RV R2xK R#5i)z  = COALESCE(sessions.z , excluded.rzNr|)rr:s& r/rrs2'[SVcU"7uKuAN[s profile_namez2 created_source = CASE WHEN zsessions.created_sourcer?zr THEN COALESCE(NULLIF(excluded.created_source, 'local'), sessions.created_source) ELSE sessions.created_source ENDc<V^8dQhR\R\R\/#)r)r:extrar+r;)r.s"r/r0r0$s!#c3r1c \R^\V4,,pV RV RV RV RV RV R2 #)zb``col = COALESCE(sessions.col, (SELECT p.col FROM parent))`` (whitespace is part of the SQL text). rrz (SELECT p.z FROM sessions p z) WHERE p.id = sessions.parent_session_idrZ)len)r:rpads&& r/_inherit_col_sqlr$sH c#h C %$SESEC5@R %8r Cr1z+UPDATE sessions SET c#8"TFp\V4xK R#5iNrrcs& r/rr1s N'M! 1  'MzAND (rzzD WHERE id = ? AND parent_session_id IS NOT NULLc#H"TFpR\RRV 24 R2xK R#5i)z% AND COALESCE( model_config$.z5, '') != parent_session_idNr>)rmarkers& r/rr:s:#7-->~QSTZS[}-],^_886s "c#8"TFp\V4xK R#5irrrs& r/rrAs!6(++6ra6 WHERE id = ? 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' )c a]tRtRtoRtV3RlRlt]V3RlRl4tRV3RlR lltV3R lR lt RV3R lR llt RV3RlRllt RRRR/V3RlRllt Rt ]!R4tV3RlRltV3RlRlt]V3RlRl4tV3RlRltV3RlR ltRV3R!lR"lltRV3R$lR%lltRV3R&lR'lltV3R(lR)ltRR*RR+R/V3R,lR-llltV3R.lR/ltRV3R0lR1lltV3R2lR3ltV3R4lR5ltRR6RR7R/V3R8lR9llltRV3R:lR;lltRlR?llt V3R@lRAlt!RV3RBlRCllt"V3RDlRElt#V3RFlRGlt$RHRRIRRJRRKRRLR#/V3RMlRNllt%V3ROlRPlt&]V3RQlRRl4t'V3RSlRTlt(V3RUlRVlt)V3RWlRXlt*V3RYlRZlt+V3R[lR\lt,V3R]lR^lt-R_R`/V3RalRbllt.R_R`/V3RclRdllt/ReR/V3RflRgllt0V3RhlRilt1]V3RjlRkl4t2]3t4V3RllRmlt5V3RnlRolt6V3RplRqlt7RV3RrlRsllt8]V3RtlRul4t9]:!0Rm4t;Rt<]V3RvlRwl4t=V3RxlRylt>Rz^R{RR|R}R~RRR/V3RlRllt?]@V3RlRl4tARV3RlRlltBV3RlRltCRV3RlRlltDRV3RlRlltEV3RlRltFV3RlRltGRV3RlRlltHRV3RlRlltIRV3RlRlltJRR#RR#RR#/V3RlRlltKV3RlRltL]V3RlRl4tMV3RlRltNV3RlRltORV3RlRlltPV3RlRltQRV3RlRlltRRV3RlRlltSRtTV3RlRltURV3RlRlltVRV3RlRlltWV3RltXRtYVtZR#)SessionSessionsMixiniOzOSession rows: create/inherit, lifecycle flags, model_config, listing, deletion.c0<V^8dQhRS[S[,/#r)r+rr-)r. __classdict__s"r/r0!SessionSessionsMixin.__annotate__Rs8C=r1c ^RIHpV!4P4p\VP4P4P pW28XdR#VP VR, 8HpV'd4\ P!RVP4'd VP#R# \d\PRRR7R#i;i) u The profile owning THIS store, from ``db_path`` alone (``/state.db`` → default, ``/profiles//state.db`` → name): a gateway serving a NON-launch profile opens that profile's store. None outside the profile tree — NULL beats a fabricated owner.)get_default_hermes_rootdefaultprofilesz[a-z0-9][a-z0-9_-]{0,63}zown-profile derivation failedT)exc_infoN) hermes_constantsrresolverdb_pathparentre fullmatchname Exceptionloggerdebug)selfrrootris_profile_dirs& r/_own_profile_name&SessionSessionsMixin._own_profile_nameRs I @*,446D$,,'//188F~ #]]dZ.??N",,/JFKK"X"X{{" I LL84L H Is$AB%B%0&B% B%%"C  C c$<V^8dQhRS[RR/#r) session_idr+Nr;)r.rs"r/r0rds A A3 A4 Ar1c bVP\V34VP\V34R#)u7NULL-fill a child's cwd/git/profile from its parent (profile_name only within the same ``agent::`` namespace). Gateway routing columns are inherited ONLY by compression forks (a crash before the gateway re-records the peer would strand the child unroutable); delegate and branch children must NOT inherit them (peer recovery could repoint traffic into a subagent's session), including when their parent row itself ended on compression — a long batch outlives its coordinator's rotation, and two live rows holding one routing key is the shape reported in #92859.N)r_INHERIT_PARENT_META_SQL_INHERIT_PARENT_ROUTING_SQLrrs&&r/ _inherit_parent_session_metadata5SessionSessionsMixin._inherit_parent_session_metadatacs& - }= 0:-@r1Nc$r<V^8dQhRS[RS[RS[R,RS[S[S[3,R,RS[R,RS[R,RS[S[,R S[R,R S[R,R S[R,R S[R,R S[R,RS[S[,RS[R,RS[R,RS[R,RS[S[,RR/#)r)rrhmodelNr system_promptuser_idrjchat_id chat_type thread_idparent_session_idr5rr3 origin_json display_nametransport_profiler+)r-r,rr)r.rs"r/r0ros-J-J-J'*-J36:-JTXY\^aYaTbeiTi-JTz-J36:-JS[\_S`-Jt-J03Tz-JNQSWZ-J: -J47: -JU]]`Ta -J Tz -J 8;Tz -J Y\^bXb -J $C= -J -Jr1c aaa^RIHo\R/RVbRVbRVbRVbRVbRVbRVbR VbR V bR V bR V bR V bRV bRVbRVbRVbRVboSPVVV3RlSPR7R#)u Upsert a session row, never overwriting what an earlier writer set (the gateway creates a bare row before create_session carries the real model/prompt) — the one exception is the token-accounting guard's placeholder ``source='unknown'``, which a later writer's real surface replaces (#111999): once minted, that placeholder otherwise labelled a real session anonymous for life, because this upsert is the only writer that could correct it. chat_id/thread_id scope gateway /resume (IDOR). Children backfill from the parent; a missing profile_name is stamped with THIS store's own (NULL reads as unowned). When ``parent_session_id`` is set (compression fork, delegate/subagent spawn, branch continuation) and this row's own ``cwd``/``git_repo_root``/ ``git_branch``/``profile_name`` are still NULL after the insert, they are backfilled from the parent row. Callers of ``create_session`` for a child session historically didn't propagate these fields themselves (e.g. the compression-fork path), so a lineage could silently lose its working directory and drop out of the project sidebar every time it forked (#64709), or lose its owning profile and be aggregated as "default" every time it rotated or branched (the cross-profile session-jump bug). This only fills NULLs — an explicit value on the child is never overwritten. For compression forks specifically (parent ended with ``end_reason='compression'``), the gateway origin columns (``user_id``/``session_key``/``chat_id``/``chat_type``/ ``thread_id``/``display_name``/``origin_json``) are inherited too, so a crash before the gateway re-records the peer can't strand the child without a recoverable routing mapping (#59527). When the caller passes no ``profile_name`` at all, the row is stamped with THIS store's own profile (:meth:`_own_profile_name`) instead of NULL. Every ``state.db`` belongs to exactly one profile — the same single-match contract :meth:`backfill_null_session_profiles` relies on — so the stamp is derivation, not a guess. Rows minted NULL after that one-shot #94724 backfill ran stayed NULL forever, and profile-keyed consumers (desktop sidebar scope matching, ``@session:/`` deep links, the fail-closed owner ladder) treat NULL as unowned: the session vanishes from the sidebar even though its transcript is intact (#99222). Stores outside the profile tree (explicit ``db_path`` in tests, ad-hoc copies) derive nothing and keep NULL — never guess. )!insert_session_row_in_transactionrrhr rr r rjr r rrr5rr3rrrc<S!SV3/SB#rr|)rrrrs&r/:SessionSessionsMixin._insert_session_row..s)J4QU)`Y_)`r1 patience_sNr|)hermes_state_worker_lifecyclerr,_execute_write_TRANSCRIPT_WRITE_PATIENCE_S)rrrhr rr r rjr r rrr5rr3rrrrrsf&&&&&&&&&&&&&&&&&@@r/_insert_session_row(SessionSessionsMixin._insert_session_rowosJ T;;F;%;Vb;$1;;B;P[;%;1:;FO;):;@C;R^;%2 ;@K ;Zf ; ): ; `'+'H'H  Jr1c,<V^8dQhRS[RS[RS[/#)r)rrhr+r;)r.rs"r/r0rs"cr1c ,VP!W3/VBV#)z9Create (upsert) a session record. Returns the session_id.r)rrrhkwargss&&&,r/create_session#SessionSessionsMixin.create_sessions   >v>r1c@<V^8dQhRS[RS[RS[R,RS[/#)r)rrhr Nr+r;)r.rs"r/r0rs/ccTXjnqr1c 0VP!W3RV/VBV#)z>Ensure a session row exists (upsert). Accepts optional kwargs.r r!)rrrhr r"s&&&&,r/ensure_session#SessionSessionsMixin.ensure_sessions    K5KFKr1Tc*<V^8dQhRS[RS[RR/#)r)r finalizedr+Nr-rr)r.rs"r/r0rs"   s  t  t  r1c VV'gR#TPRV'd^M^V34R#)zZMirror ``SessionEntry.expiry_finalized`` so it survives a lost sessions.json. See #9006. Nz5UPDATE sessions SET expiry_finalized = ? WHERE id = ?) _write_sql)rrr*s&&&r/set_expiry_finalized)SessionSessionsMixin.set_expiry_finalizeds&    C9aZ[]gEh r1rr c h<V^8dQhRS[RS[RS[S[,RS[S[,RS[S[,/#)r)platformr rr r+r-r)r.rs"r/r0rsC"""),"9A#"#" #"r1c V'dVR 9dR#RpV\V4.pVe$VR, pVP\V44VPVR,V4Uu.uFp\V4NK ppV'gR#V'dzVUu.uF9p\VP R4;'gR4\V48XgK7VNK; p pV 'd\V ^,R,4#\ V4^8dR#M2\ RV4U u0uFq'gK V kK up 4^8dR#\V^,R,4#uupiuupiuup i) uMost recent live session_id for source + chat_id (+ thread_id). With ``user_id`` exact sender matches win; several distinct users and no match → None (never another participant's session).Nr4z SELECT id, user_id, started_at FROM sessions WHERE LOWER(source) = LOWER(?) AND session_key IS NOT NULL AND chat_id = ? AND ended_at IS NULL z AND COALESCE(thread_id, '') = ?z ORDER BY started_at DESCr rc3"TF7p\VPR4;'gR4P4xK9 R#5i)r r4N)r-r6r7)rrs& r/r>SessionSessionsMixin.find_session_by_origin..s2P4ac!%% "2"8"8b9??AA4s !AA)Nr4)r-r} _read_allr,r6r) rr1r rr queryrrrowsexactus &$$$$ r/find_session_by_origin+SessionSessionsMixin.find_session_by_origins0 7j0 !#g,/  7 7E MM#i. )!%8S0SU[!\]!\AQ!\]  $T1AEE),<,B,B(Cs7|(SQQET58D>**4y1} P4PVPTU!!PV WZ[ [474=!!^U Ws$#E!E1EE E"Eg @z{alias}c*<V^8dQhRS[RS[RR/#)r)r end_reasonr+Nr;)r.rs"r/r0rs"  c s t r1c :aaaSPVVV3Rl4R#)zMark a session ended; the first end_reason wins (a compression split must keep ``'compression'`` even if a stale end_session() lands later); reopen_session() to re-end.cZ<SPVR\P!4SS3SS4#)zRUPDATE sessions SET ended_at = ?, end_reason = ? WHERE id = ? AND ended_at IS NULL) _end_and_bumptime)rr>rrs&r/r2SessionSessionsMixin.end_session..s*);); f YY[*j 1:z* r1Nr)rrr>sfffr/ end_session SessionSessionsMixin.end_sessions   r1c 8<V^8dQhRS[RS[RS[RS[RS[/#)r)sqlrrreasonr+)r-rMrs)r.rs"r/r0rs2sEsTW\_r1c pVPW#4PpV'dVPWV4V#)zRun an end-stamp UPDATE; only a boundary this call actually wrote advances the conversation generation (a no-op must not rotate the peer). Returns rowcount.)rrowcount_bump_conversation_generation)rrrHrrrIchangeds&&&&&& r/rA"SessionSessionsMixin._end_and_bumps0,,s+44   . .t Hr1c&<V^8dQhRS[RS[/#r)rr+r-rs)r.rs"r/r0rsCCr1c nVPR\RR\,4 R2V34P#)zXThe still-marked == never-drained accept-row UPDATE (#125577), on a caller's connection.zbUPDATE messages SET active = 0 WHERE session_id = ? AND role = 'user' AND active = 1 AND COALESCE(display_metadatarz, 0) = 1)rrrrKrs&&r/!_retire_undrained_queue_rows_conn6SessionSessionsMixin._retire_undrained_queue_rows_connsE|| -.@$IcBcdeem oM  (  r1c&<V^8dQhRS[RS[/#rPrQ)r.rs"r/r0rsSScScSr1c 2aaSPVV3Rl4#)u<Deactivate busy-queue accept rows that never drained (#125577): a restart discarded the in-memory queue, so nothing re-placed/deactivated the row written at accept time and alternation repair would glue the never-run prompt into the previous turn's user message. The drain's replacement row carries no marker, so still-marked == never drained; a dispatched-then-interrupted turn's row is never marked (its discard is handled in-process, #123532). Deactivated, never deleted — the row stays as history. Split out of :meth:`reopen_session` so the read-only mount paths (#85303: resume, lazy watch, hydration) can retire stale accept rows WITHOUT clearing ``ended_at`` — after a restart the marked row would otherwise stay active and visible on every mount until the next send. Idempotent; returns the number of rows retired. c(<SPVS4#r)rTrrrs&r/rBSessionSessionsMixin.retire_undrained_queue_rows..s??jQr1rDrrsffr/retire_undrained_queue_rows0SessionSessionsMixin.retire_undrained_queue_rowss"" QS Sr1c$<V^8dQhRS[RR/#rr;)r.rs"r/r0rs!!!!r1c :aaVV3RlpSPV4R#)apClear ended_at/end_reason so a session can be resumed; first freeze markerless legacy reset children, skipping explicit fork/delegate provenance and children that predate the parent itself. The guard compares against the parent's started_at, not its current ended_at: a parent that was reopened and re-ended later still owns reset children from its earlier boundaries.c,<SPVS4VPR\RR4 R\RR4 R\RR4 R\R\ \ 44 2S.\ O54VPRS34SP VS4R #) zUPDATE sessions AS child SET model_config = json_set(COALESCE(child.model_config, '{}'), '$._reset_from', child.parent_session_id) WHERE child.parent_session_id = ? AND rz $._reset_fromrrr=z IS NULL AND COALESCE(child.source, '') != 'tool' AND child.started_at >= (SELECT p.started_at FROM sessions p WHERE p.id = child.parent_session_id) AND rCUPDATE sessions SET ended_at = NULL, end_reason = NULL WHERE id = ?N)rTrrrr~r _unarchive_auto_archived_lineagerYs&r/_do0SessionSessionsMixin.reopen_session.._do s  2 24 D LL99JK_ap9q8rs()=?QRST()=?QRST/w8QRd8efgi101  LLUXbWd   1 1$ Cr1NrD)rrrcsff r/reopen_session#SessionSessionsMixin.reopen_sessions  D$ C r1c,<V^8dQhRS[RS[RS[/#)r)rrIr+r+)r.rs"r/r0rs#3Z^r1c aaaaS'gR#\P!4o\SPVVVV3Rl44# \dR#i;i)aBDurably mark an intentional reset boundary on live rows or rows with a *recoverable* accidental end_reason (explicit boundaries are preserved): an ``agent_close`` row left recoverable would be resurrected by stale-route recovery. Keep in sync with find_latest_gateway_session_for_peer. Plain ``end_session()`` is NOT sufficient for reset boundaries: it no-ops on an already-ended row, so a row that agent cleanup already closed as ``agent_close`` would stay recoverable and stale-route recovery would resurrect the reset session with its full history (#61220, #61993, #63539). FcD<SPVR\ R2SSS3SS4#)zfUPDATE sessions SET ended_at = ?, end_reason = ? WHERE id = ? AND (ended_at IS NULL OR end_reason IN (rZ)rAr)rnowrIrrs&r/r?SessionSessionsMixin.promote_to_session_reset..-s49K9K%%A$B"Ffj):v:r1)rBrrrr)rrrIrjsfff@r/promote_to_session_reset-SessionSessionsMixin.promote_to_session_resetsNiik ++-    s A AAFc n<V^8dQhRS[RS[RS[S[,RS[S[,RS[RS[S[,/#)r)rr5 git_branchr3replace_git_metar+)r-rrrrs)r.rs"r/r0r5sK((($'(5=c](}(?C( #(r1c aaaaaS'd S'gR#T;'gRP4oT;'gRP4oVVVVV3RlpVPV4#)a`Persist the authoritative cwd and claim a Git metadata generation. git fields are written only when non-empty (a probe failure never clobbers a value) except under ``replace_git_meta`` (a workspace MOVE overwrites the old repo identity). Async probes publish with the returned generation so an older worker cannot overwrite a newer claim (A -> B -> A).Nr4cB<VPRS 34P4pVfR#RR.pS.pV^,S8wg S 'd:VPR 4TPS;'gRS ;'gR34M@RS3RS 33F4wrEV'gKVPV R24VPV4K6 VPRRP V4 R 2.VOS N4VPR S 34P4pVfR#\ V^,4#) z%SELECT cwd FROM sessions WHERE id = ?Nzcwd = ?zBgit_metadata_generation = COALESCE(git_metadata_generation, 0) + 1ror3 = ?UPDATE sessions SET , z WHERE id = ?z9SELECT git_metadata_generation FROM sessions WHERE id = ?)zgit_branch = ?zgit_repo_root = ?)rfetchonerr}rers) rcurrentsetsrr:valr*branchr5rp repo_rootrs & r/rc4SessionSessionsMixin.update_session_cwd.._doAsll#JZMZcceGcdD!$FqzS $4 CD v~~y/@/@DAB".!7/99U VHCs se4L1 c*!W LL/ $/@ NPeRXPeZdPe f,,Kj]hj ;4 7CAK 7r1)r7r) rrr5ror3rprcrzr{s &ff&&f @@r/update_session_cwd'SessionSessionsMixin.update_session_cwd5sV""))+"((b//1  8 8&""3''r1c ^<V^8dQhRS[RS[RS[RS[S[,RS[S[,RS[/#)r)rr5 generationror3r+)r-rsrrr)r.rs"r/r0rVsG$'58FNsm} r1c  \V\4;'d#\V\4'*;'dV^8pV'dV'd V'gR#RT;'gRP43RT;'gRP433UUu.uFwrxV'gKWx3NK p ppV 'gR#TP RRP RV 44 R2V U Uu.uFwrVNK upp WV.,4^8H#uuppiuupp i) zAPublish async Git enrichment only while its cwd claim is current.Fror4r3rtruc30"TF wrV R2xK R#5i)rsNr|)rr:_s& r/rDSessionSessionsMixin.publish_session_git_metadata..fs,OfcuD\sz9 WHERE id = ? AND cwd = ? AND git_metadata_generation = ?)rDrsrrr7_write_rowcountre) rrr5rror3valid_generationr:ryfieldsrs &&&&&& r/publish_session_git_metadata1SessionSessionsMixin.publish_session_git_metadataVs &j#6ooz*VZ?[;[oo`jno`o,< 0 0b779:_}ObOb`bNiNiNkRtyy{;  R0=-j9?? 66  r1c$<V^8dQhRS[RR/#rr;)r.rs"r/r0rs    r1c V'gR#VPRV34pVeGV^,'g8V^,'d'V^,\PP 8XdR#VP RR\PP V3VPR7R# \PdRpLi;i)aClear activity labels after a turn (``last_activity_at`` is kept so idle / watchdog clocks stay continuous). A no-op clear skips the write transaction. Description and provenance are observation labels for *what was happening at* that timestamp during an active turn; once the turn is idle they must not keep advertising "compressing" / "executing tool" (#72039). Response-critical-path contract (#76354 review S1): runs in the turn's ``finally``; a no-op clear (labels already empty) skips the write transaction entirely, and a real clear uses the same short sub-second busy budget as :meth:`touch_session_activity` instead of the full routine write patience. NzUSELECT last_activity_description, last_activity_provenance FROM sessions WHERE id = ?z\UPDATE sessions SET last_activity_description = ?, last_activity_provenance = ? WHERE id = ?r4r) _read_onesqlite3Errorr UNKNOWNrr-rrrr*s&& r/clear_session_activity_labels2SessionSessionsMixin.clear_session_activity_labelss  ..g C ?3q663q66SVGYGaGaGgGg=g   j #++11: >4KjKj  }} C sB$$B>=B>c@<V^8dQhRS[RS[RS[S[,RR/#)r)rmodel_config_jsonr r+Nr2)r.rs"r/r0rs1   25 >Fsm  r1c NVP4VPRW#V34R#)z4Update model_config and (COALESCE) optionally model.zMUPDATE sessions SET model_config = ?, model = COALESCE(?, model) WHERE id = ?N)flush_token_countsr-)rrrr s&&&&r/update_session_meta(SessionSessionsMixin.update_session_metas' !  [ z 2 r1c:<V^8dQhRS[RS[S[,RR/#)r)rr r+Nr2)r.rs"r/r0rs'!!s!8C=!UY!r1c >aaaVVV3RlpSPV4R#)z0Store the full assembled system prompt snapshot.cr<VPRSPVS4S34SPV4R#)zMUPDATE sessions SET system_prompt_hash = ?, system_prompt = NULL WHERE id = ?Nr_store_system_prompt#_delete_unreferenced_system_prompts)rrrr s&r/rc6SessionSessionsMixin.update_system_prompt.._dos7 LL_**4?L   4 4T :r1NrD)rrr rcsfff r/update_system_prompt)SessionSessionsMixin.update_system_prompts ; C r1c*<V^8dQhRS[RS[RR/#)r)rpinr+Nr-r)r.rs"r/r0rs" ! !C !c !d !r1c vaaaVe\P!V4MRoVVV3RlpSPV4R#)aaPersist the session's ``tools[]`` pin (JSON-serializable) so a rebuilt AIAgent sends the same bytes; ``None`` clears. The array repeats across sessions like a system prompt does, so it is stored in the same content-addressed ``system_prompts`` table and the column holds its hash (legacy rows: an inline JSON name list); ``get_session`` resolves either.Ncr<VPRSPVS4S34SPV4R#)z/UPDATE sessions SET tool_names = ? WHERE id = ?Nr)rpayloadrrs&r/rc;SessionSessionsMixin.update_session_tool_names.._dos6 LLJ33D'BJO Q  4 4T :r1)rEdumpsr)rrrrcrsff& @r/update_session_tool_names.SessionSessionsMixin.update_session_tool_namess- &)_$**S/$ ; C r1base_urlapi_modec l<V^8dQhRS[RS[RS[S[,RS[S[,RS[S[,RR/#)r)rr providerrrr+Nr2)r.rs"r/r0rsK   &) 5=c] 3- 2:3-   r1c aaVP4RR/pS'dSVR&V'd/RTRT;'gRRT;'gR/pVPWwR7VPSVRVV3R l4R#) aSet the model after a mid-session /model switch (unconditionally) and drop any Browser runtime lock (lineage markers survive). Route writers never touch the stored prompt; ``_stored_prompt_matches_runtime`` decides staleness. When *provider* is given the whole route is written, in both shapes resume reads (top-level keys for the TUI/Desktop, ``gateway_runtime`` for the CLI), so a later resume recombines the model with the provider that serves it (#79536). ``base_url``/``api_mode`` are always replaced then (``None`` deletes): the previous provider's endpoint must not survive a switch, or resume sends the new provider's model to the old host. Callers without provider knowledge leave the stored route untouched. browser_model_lockNr rrr)gateway_runtimez.s E6:6r1)rupdate_write_model_config_patch)rrr rrrpatchroutes&ff&$$ r/update_session_model)SessionSessionsMixin.update_session_modelsu$ !!5t < "E'N :x7G7G4U]UeUeaefE LLL 6 && ] 6 r1c <V^8dQhRS[RS[S[S[3,RS[RS[S[S[S[,.S[3,,RR/#)r)rrrHrr+N)r-r,rrrrM)r.rs"r/r0rsV ! ! !&*38n !  !8C=/5"89: !  !r1c FaaaaaVVVVV3RlpSPV4R#)zMerge ``patch`` into model_config then run ``sql`` with ``params(merged)`` in one write transaction; no-op when the row doesn't exist.c<SPVSS4pV\JdR#TPSS'dS!V44R#VS34R#r)_merge_model_config_json_MODEL_CONFIG_ROW_MISSINGr)rrrrrrrHs& r/rc;SessionSessionsMixin._write_model_config_patch.._dosA224UKF22 LLfVn QVZ

?CCCQQr1c Z<V^8dQhRS[RS[RS[S[.S[3,RS[S[,/#)r)rrXrr+)r-rrr)r.rs"r/r0rsBUUU3U7?s 7KUPXY\P]Ur1c ^RIHpV!WW#4#)z\Write ``update(value)`` of a conversation-wide key at the compression tip (one transaction).)&update_conversation_model_config_value)"hermes_state_sessions_model_configr)rrrXrrs&&&& r/r;SessionSessionsMixin.update_conversation_model_config_values ^5dTTr1c6<V^8dQhRS[RS[S[,/#rWr-rN)r.rs"r/r0rs<.2s FE:6r1N)rrrBr)rrr rrrrlocks&fd$$$$ r/update_session_runtime_lock0SessionSessionsMixin.update_session_runtime_lock!sv B"o}ObOb`b L..B T)_l\`\e\e\g  && -t4 # 7  r1c*<V^8dQhRS[RS[RR/#)r)renabledr+Nr+)r.rs"r/r0r5s'QQ3QQ$Qr1c TV'gR#VPVR\V4/4R#)zZPersist the per-session YOLO flag so ``/yolo`` survives ``--resume``; no-op without a row.N yolo_mode)rrr)rrrs&&&r/set_session_yolo%SessionSessionsMixin.set_session_yolo5s!  &&zKg3OPr1cL<V^8dQhRS[S[S[S[3,,RS[/#)r) session_metar+)rr,r-rrr)r.rs"r/r0r<s,dd8DcN+Cddr1c z\\T;'g/PR44PR44#)zVPersisted YOLO flag; False on any parse failure (resume must never enable the bypass).rr)rrrIr6)rs&r/session_yolo_enabled)SessionSessionsMixin.session_yolo_enabled;s4'););(@(@(PQUUVabccr1cL<V^8dQhRS[RS[S[S[S[3,,/#rPr-rr,r)r.rs"r/r0r@s( <  'unknown' AND billing_provider <> '' ORDER BY last_seen DESC, rowid DESC LIMIT 1N)rrr,rs&& r/get_recent_session_model_route3SessionSessionsMixin.get_recent_session_model_routeUs= !nn M   tCy)T)r1c6<V^8dQhRS[RS[S[,/#)r)session_id_or_prefixr+r2)r.rs"r/r0rks ? ?s ?x} ?r1c VPV4pV'd VR,#VPR\V4 R234p\V4^8XdV^,R,#R#)z>Exact id, else the single unambiguous prefix match, else None.rzSSELECT id FROM sessions WHERE id LIKE ? ESCAPE '\' ORDER BY started_at DESC LIMIT 2%N)rr6rRr)rrr9matchess&& r/resolve_session_id'SessionSessionsMixin.resolve_session_idksf  !56 ; .. b1231 5 7 $'w<1#4wqz$>$>r1c&<V^8dQhRS[RS[/#)r)rr+rQ)r.rs"r/r0rvs33r1c T;'gRP4pV'g^#\VPRV34;'g^4#)u9Stamp this store's own profile onto legacy ``profile_name IS NULL`` rows, which the fail-closed owner ladder cannot route. Never overwrites a non-NULL owner. Returns rows stamped. Sessions created before the durable-ownership work (#95407 lineage) carry ``profile_name = NULL``. On single-backend installs that was harmless, but once a Desktop registers a second connection the fail-closed owner ladder (which is correct for new sessions) can no longer route those rows anywhere — every pre-campaign session becomes unresumable after upgrade (#94724, field report). r4zvUPDATE sessions SET profile_name = ? WHERE profile_name IS NULL OR TRIM(profile_name) = '')r7rsr)rrstamps&& r/backfill_null_session_profiles3SessionSessionsMixin.backfill_null_session_profilesvsV##**,4'' FH     r1c <V^8dQhRS[/#rrs)r.rs"r/r0rs#r1c L\VPRR4;'g^4#)uPromote ``model_config.cwd`` into the cwd column for ACP rows lacking one. ACP sessions minted before the adapter populated the column still carry their workspace inside ``model_config``, written by the same adapter that knew the real directory — so this is a record being promoted, not a guess. Only fills NULL/empty; an explicit column value always wins. Returns the number of rows changed. aUPDATE sessions SET cwd = json_extract(model_config, '$.cwd') WHERE source = 'acp' AND COALESCE(cwd, '') = '' AND json_valid(model_config) AND COALESCE(json_extract(model_config, '$.cwd'), '') != ''r|)rsrrs&r/backfill_acp_session_cwd-SessionSessionsMixin.backfill_acp_session_cwds84'' Q   r1 extra_set_sqlr4c 8<V^8dQhRS[RS[RS[RS[RS[/#)r)columnrrr+r+)r-rrr)r.rs"r/r0rs2  # 3 s +. 8< r1c  Paaaaa\SPVVVVV3Rl44#)zSet one ``sessions`` column across a whole compression lineage: Desktop projects roots forward to their tip, so updating only the tip would let the root resurrect it on refresh. *extra_set_sql* (trusted literal, ``, col = expr``) rides the same UPDATE.c0<SPVSSSSR7#)r+)"_set_lineage_column_in_transaction)rr-r+rrrs&r/r:SessionSessionsMixin._set_lineage_column..s"@@fj%}ANr1)rrr)rr-rrr+sffffdr/_set_lineage_column(SessionSessionsMixin._set_lineage_columns+ D'' N N   r1c2<V^8dQhRS[RS[RS[RS[/#)r)r-rrr+r)r.rs"r/r0rs,sPS\_:=r1c VR8Xd V'gRpVP\RV RV R2,W3V34P4Uu.uF qf^,NK up#uupi)aReturn affected IDs so authority revisions share this exact lineage selector. A plain ``archived`` write (canonical mutation, user/CLI/API) is the DELIBERATE archive and clears the idle sweep's ``auto_archived`` provenance, same as :meth:`set_session_archived`.archived, auto_archived = 0z- UPDATE sessions SET rszW WHERE id IN (SELECT id FROM lineage) RETURNING id )r_LINEAGE_CTE_SQLr)rrr-rrr+r*s&&&&&$ r/r17SessionSessionsMixin._set_lineage_column_in_transactions Z  1M"&,, $]O,    U +#  (*##3A# sAnotifyc2<V^8dQhRS[RS[RS[RS[/#)r)rr7r;r+r+)r.rs"r/r0rs*sdt_cr1c aaaVVV3RlpSPV4wrVV'dV'd\SVRSR7\V4#)aSoft-hide (or unhide) a session and its compression lineage; messages are kept. This is the DELIBERATE archive (user, CLI, API): it clears the ``auto_archived`` provenance, so re-activation never un-hides it on the user's behalf. A real unarchived -> archived flip fires ``on_session_delete`` (``reason="archive"``) after commit; ``notify=False`` is for housekeeping that hides a row whose session lives on elsewhere.c<VPRS34P4pSPVRS\S4RR7pT\ S;'d%T;'dVRJ;'dV^,'*43#)z*SELECT archived FROM sessions WHERE id = ?r7r8r0N)rrvr1rsrr)rr*rr7rrs& r/rc6SessionSessionsMixin.set_session_archived.._dosw,,Kj][ddfC99j*c(mK`:bCXPP#PP#T/PP#a&jQQ Qr1archive)rIprimary)rr"rr)rrr7r;rcrnewly_archivedsfff$ r/set_session_archived)SessionSessionsMixin.set_session_archiveds;  R #11#6 f s9j QCyr1c&<V^8dQhRS[RS[/#rPr+)r.rs"r/r0rsddddr1c ,VPRV^RR7#)a&The idle sweep's archive: like :meth:`set_session_archived` but stamps ``auto_archived`` on the rows IT hides. A row already archived keeps its provenance, so a deliberately archived ancestor is never relabelled as sweep-owned (SQLite evaluates every SET expression against the pre-update row).r7zF, auto_archived = CASE WHEN archived = 0 THEN 1 ELSE auto_archived ENDr0)r3r[s&&r/_auto_archive_lineage*SessionSessionsMixin._auto_archive_lineages( ''  Ab(d dr1c&<V^8dQhRS[RS[/#rPr+)r.rs"r/r0rs&&3&4&r1c W3pVP\R,V4P4pVeR#VP\R,V4P^8#)aUn-hide a lineage the idle sweep archived, on *conn* (caller's write txn). A tip that is published (compression) or reopened (resume) under it is live again, and the listing admits a lineage by its ROOT's flag, so leaving the sweep's stamp would hide an active chat (#117713). A lineage with ANY deliberately archived row (``archived = 1 AND auto_archived = 0``) is left alone: a manual archive stays until the user un-archives it. True when rows were un-hidden.z SELECT 1 FROM sessions WHERE id IN (SELECT id FROM lineage) AND archived <> 0 AND COALESCE(auto_archived, 0) = 0 LIMIT 1 Fz UPDATE sessions SET archived = 0, auto_archived = 0 WHERE id IN (SELECT id FROM lineage) AND archived <> 0 )rr9rvrK)rrrmanuals&& r/rb5SessionSessionsMixin._unarchive_auto_archived_lineagest)     "   ||    "A & &r1c&<V^8dQhRS[RS[/#rPr+)r.rs"r/r0rs%%%%r1c V'gR#VPV4pT'dTPR4'gR#TpTPT4;'gTpYA8wdTPT4;'gTpTPR4;'gRTP9dR#TP TR4'gR#TP RTR,34R# \dR#i;i \dLi;i)uUn-archive a session archived by a recoverable accident (ws_orphan_reap, agent_close); deliberate archives are left alone. True when un-archived. Registry-style lookups (Bot Mode's canonical "Bot Chat") use this to resurrect a row the ws-orphan reaper (``ws_orphan_reap``) or older agent cleanup (``agent_close``) archived: those ends are accidents, not user intent, so the identity-scoped canonical chat must survive them (#92687). Sessions archived with no end_reason or an explicit boundary reason (user archived deliberately, ``session_reset``, …) are left untouched — returns ``False`` for those, ``True`` only when the row was archived for a recoverable reason and is now un-archived (whole compression lineage, via :meth:`set_session_archived`). Fr7r>r4rarT)rrr6get_compression_tipRECOVERABLE_END_REASONSrCr-)rrr*tiptip_ids&& r/unarchive_recoverable_session2SessionSessionsMixin.unarchive_recoverable_sessions "":.C#''*-- --j9GGZF#&&v.55# GGL ! ' 'R0L0L L((U;;  QTWX\T]S_ +     s/CC1 C1:C1 C.-C.1 C?>C?c,<V^8dQhRS[RS[RS[/#)r)rpinnedr+r+)r.rs"r/r0rs"S$4r1c `VPRV\V44pV'dVPV4p\V4;'dK\VP R44;'d)VP R4;'gRVP 8HpV'gVPRV^4V#)aPin/unpin a session and its compression lineage (pins are exempt from the auto_archive sweep). Pinning also clears ``hidden``: a pin means "keep this visible", and a hidden+pinned row is otherwise absent from both the default listing and the pinned back-fill (see #106171). Exempt the canonical Bot Chat (hidden + exact registry title): the desktop contract keeps it hidden and reachable only through the bot row, and unhiding it would also disable the rename guard in ``_set_session_title`` that protects its identity (see review on #106180).rVhiddentitler4)r3rsrrrr6CANONICAL_BOT_CHAT_TITLE)rrrVresultr*is_canonical_bot_chats&&& r/set_session_pinned'SessionSessionsMixin.set_session_pinneds))(JF L "":.C$(I%%$swwx7H2I%%!''RD,I,II ")((:qA r1c,<V^8dQhRS[RS[RS[/#)r)rrXr+r+)r.rs"r/r0r"s'KKSK$K4Kr1c :VPRV\V44#)z\Hide/unhide a session and its compression lineage from the default listing; still resumable.rX)r3rs)rrrXs&&&r/set_session_hidden'SessionSessionsMixin.set_session_hidden"s''*c&kJJr1c,<V^8dQhRS[RS[RS[/#)r)rreadr+r+)r.rs"r/r0r&s'bb3bdbdbr1c hTPRY'd\P!44#R4#)zMark read/unread across the compression lineage. ``last_read_at`` is a watermark: unread when activity postdates it (no write on the message path). NULL = never tracked = read; 0 = unread. last_read_at)r3rB)rrrds&&&r/set_session_read%SessionSessionsMixin.set_session_read&s+'' SWDIIKaa]`aar1c<<V^8dQhRS[S[S[3,RS[/#)r) session_rowr+)r,r-rrr)r.rs"r/r0r,s#::DcN:t:r1c VPR4pVfR#VPR4;'gVPR4p\T;'g^4\V48#)zIUnread = activity postdates the ``last_read_at`` watermark (NULL = read).rfF last_active started_at)r6r)rk last_readrms& r/session_unread#SessionSessionsMixin.session_unread+sW OON3  !oom4UU  8U [%%A&y)999r1c X<V^8dQhRS[RS[RS[RS[S[S[S[,3,/#)r) where_sql id_needle search_needler+)r-rMrNr)r.rs"r/r0r;sB ] ]s ]s ]3 ]SXY\^bcf^gYgSh ]r1c .p.pRRlpV'd)VPR4VPV!V44V'dz\P!RRV4pRpVPV!V4.^,4V'd!VR, pVPV!V44VPVR,4V'gW3#R P V4pV'd V R V 2V3#R V 2V3#) aExtend ``where_sql`` with the id_query / search_query filters: a row is admitted when its own id or any id in its forward compression chain matches (search also matches titles and a punctuation-stripped form so ``an94`` finds ``AN-94``); chain membership bounds the LIKE.c0V^8dQhR\R\/#)r)needler+r;)r.s"r/r0>SessionSessionsMixin._chain_search_where..__annotate__As / / / /r1c R\V4 R2#)r)rR)rxs&r/like6SessionSessionsMixin._chain_search_where..likeAs|F+,A. .r1znEXISTS (SELECT 1 FROM chain cq WHERE cq.root_id = s.id AND LOWER(cq.cur_id) LIKE ? ESCAPE '\')z[\W_]+r4zEXISTS (SELECT 1 FROM chain cq JOIN sessions cs ON cs.id = cq.cur_id WHERE cq.root_id = s.id AND (LOWER(COALESCE(cs.title, '')) LIKE ? ESCAPE '\' OR LOWER(cq.cur_id) LIKE ? ESCAPE '\'z{ OR REPLACE(REPLACE(REPLACE(REPLACE(LOWER(COALESCE(cs.title, '')), '-', ''), '_', ''), '.', ''), ' ', '') LIKE ? ESCAPE '\'rZrdrc)r}rsubrre) rsrtrurr_r{compact_needle search_clausecombineds &&& r/_chain_search_where(SessionSessionsMixin._chain_search_where:s  /  NNE  MM$y/ * VVIr=AN:  MM4 ./!3 4Q  d>23 NN=4/ 0$ $<<(1:9+U8*-V\\\& @SV\\\r1c x<V^8dQhRS[S[S[S[3,,RS[RS[S[S[S[3,,/#)r)sessions compact_rowsr+)rNr,r-rrr)r.rs"r/r0r]sC**$tCH~2F*VZ*_cdhilnqiqdr_s*r1c /pVF_pVPR4R8XgKVPVR,4pV'gK=VR ,VR,8wgKTWSVR,&Ka V'd8TPVP4Uu0uF qUR ,kK upVR7M/p.pVFpVPVR,4pV'dVPVR ,4MRpV'gVP V4KX\ V4p R Fp W9gK W,W&K V PR4fVPR4V R&VR,V R&WYR&RV R &VP V 4K V#uupi) zReplace each compression root's surfaced fields with its live tip's (root ``started_at`` kept for stable ordering), one batched query. ``_lineage_ids`` carries every chain id (a tile may hold a MIDDLE segment's id).r> compressionr)rNrY_lineage_root_id _lineage_idscontinuation_kind) rended_atr> message_counttool_call_countrYrmpreviewr r r5ror3)r6get_compression_chain_get_session_rich_rows_batchrr}r,) rrr chain_by_rootschaintip_rows projectedtip_rowrrXs &&& r/_project_compression_tips.SessionSessionsMixin._project_compression_tips]su/1 Auu\"m3221T7;5U2Y!D'1-2!D'*   - -(5(<(<(>?(>ur(>?l . $&   A!%%ag.E16hll59-DG  #!WF>"),FK  zz'"*#$%%.w)*4F% &%*> " +8F& '   V $34=@s E>limitrktimeout_secondsg@candidate_limit lineage_limitc<V^8dQhRS[RS[S[,R,RS[RS[R,RS[R,RS[S[S[S[3,,/#)r)rrkNrrrr+)rsrNr-rr,r)r.rs"r/r0rsonnncT) n  n t nTzn d38n nr1c aa\^\V44p\R\V44pVf\^V^,4p\V\\V4R44pVf\RV^,4p\V\\V4R44pRR\ R4 R2.p.pV'd?R P R V44pVP R V R 24VPV4R P V4p R\ R4 R2p RV RV RV RV R\R4 RV R\R4 R\ R\ R4 R2p VVVVV.,p \P!4V,oRoRVV3Rllp VP4;_uu_4pVPV R 4VPW4P!4pVPR^4RRR4.pXFWpTP-T4p\/TP1R%R&44TR'&TP3T4TR(&TP T4KY T# TPR^4i;i +'giL;i \"P$d>pS'd0R!\'T4P)49d\+R"TR# R$24ThhRp?ii;i))aLatency-bounded recent-conversation browse (``session_search()``): preselect a small candidate set from the indexed durable activity timestamp (fallback ``started_at``), resolve only those across compression ancestry/chains, then hydrate activity/previews for that bounded set. Lineage traversal uses ``UNION`` plus a total-row ceiling so a corrupt cycle or a deep/branching lineage cannot defeat the bound; a lineage that hits the ceiling before a terminal root/tip is omitted, not expanded. A cooperative SQLite progress deadline interrupts sustained work past ``timeout_seconds`` and raises ``TimeoutError`` (cheap statements may finish between callbacks). Supports only the agent-tool browse filters; rich callers keep using :meth:`list_sessions_rich`.rgNii r{ s.hidden = 0rvrx,c3&"TFpRxK R#5i)?Nr|)rrs& r/rDSessionSessionsMixin.list_recent_sessions_bounded..s#AACsryrzrdz parent.end_reason = 'compression' AND child.parent_session_id = parent.id AND json_extract( COALESCE(child.model_config, '{}'), '$._branched_from' ) IS NULL AND rzF IS NULL AND COALESCE(child.source, '') != 'tool' z WITH RECURSIVE recent_candidates(id) AS ( SELECT s.id FROM sessions s WHERE a ORDER BY COALESCE(s.last_activity_at, s.started_at) DESC, s.started_at DESC, s.id DESC LIMIT ? ), ancestors(candidate_id, cur_id) AS ( SELECT id, id FROM recent_candidates UNION SELECT a.candidate_id, parent.id FROM ancestors a JOIN sessions child ON child.id = a.cur_id JOIN sessions parent ON aZ LIMIT ? ), candidate_roots(root_id) AS ( SELECT DISTINCT a.cur_id FROM ancestors a JOIN sessions child ON child.id = a.cur_id WHERE NOT EXISTS ( SELECT 1 FROM sessions parent WHERE aI ) ), chain(root_id, cur_id) AS ( SELECT root_id, root_id FROM candidate_roots UNION SELECT c.root_id, child.id FROM chain c JOIN sessions parent ON parent.id = c.cur_id JOIN sessions child ON z LIMIT ? ), chain_rows AS ( SELECT c.root_id, c.cur_id, zc.cur_idz AS activity, CASE WHEN EXISTS ( SELECT 1 FROM sessions parent JOIN sessions child ON az WHERE parent.id = c.cur_id ) THEN 0 ELSE 1 END AS is_tip FROM chain c ), ranked_tips AS ( SELECT root_id, cur_id, activity, ROW_NUMBER() OVER ( PARTITION BY root_id ORDER BY activity DESC, cur_id DESC ) AS rank_in_root FROM chain_rows WHERE is_tip = 1 ) SELECT tip.id, tip.source, tip.model, COALESCE(tip.title, s.title) AS title, s.started_at AS started_at, tip.ended_at, tip.end_reason, tip.message_count, tip.tool_call_count, rt.activity AS last_active, ztip.idah, CASE WHEN s.id != tip.id THEN s.id ELSE NULL END AS _lineage_root_id FROM ranked_tips rt JOIN sessions s ON s.id = rt.root_id JOIN sessions tip ON tip.id = rt.cur_id WHERE rt.rank_in_root = 1 AND s.archived = 0 AND s.hidden = 0 AND z AND zk IS NULL ORDER BY rt.activity DESC, s.started_at DESC, tip.id DESC LIMIT ? Fc$V^8dQhR\/#rr&)r.s"r/r0GSessionSessionsMixin.list_recent_sessions_bounded..__annotate__s  C r1cD<\P!4S8dRo^#^#T)rB monotonic)deadlineinterrupted_by_deadlinesr/_deadline_progress_handlerUSessionSessionsMixin.list_recent_sessions_bounded.._deadline_progress_handlers~~8+*.'r1i interruptzrecent-session browse exceeded gz s deadline _preview_rawr4runread)maxrsrminr@rer}rrrrrBr _read_ctxset_progress_handlerrrrOperationalErrorr-r TimeoutErrorrrrrp)rrrkrrrcandidate_clausescandidate_params placeholderscandidate_wherecompression_parent_edger7rrrr8excrr*rrrs&$$$$$ @@r/list_recent_sessions_bounded1SessionSessionsMixin.list_recent_sessions_boundeds"As5z"c5#9:  "!#uqy1OeS_)=t%DE  o&9:MOS]1CT-JK   "#345X >  ') 88#A#AAL  $ $'8a%H I  # #O 4!,,'89' %%9:;< #  '' ()*A(A B33 4()@'@A4J?@A01H/HI2"(+, -''(&'789: cT j"     %   >>#o5"'   !!T))*DdK7<<6??AD--dA6 "C,,S1G!/ NB0O!PGI  $ 3 3G P>Pb=W=W=Y=_=_=a& "K77@kB--ACUVWX,-ACUVWX 0 7 7' BCD >%3PQ3PCDNN3'3PQ )12A$H2,A%5!5f'"35[_"3K` - )NM "-%%n5+D.-P  ! !. 1%n5L  6s;<=  L ~~lMBNN3'T7(*LL4)OOA& C $,<55h MH  B.x?HA--a0AhKMR 3s (M!M&cL<V^8dQhRS[S[,RS[S[S[3,/#r) session_idsr+)rNr-r,)r.rs"r/r0rs'd3iDcNr1c RT;'g.Uu.uFq"'gK VNK ppV'g/#VUu/uFq"RbK ppVPR\V4 R2V4pVF8p\VR,\VR,4VR,R7WFR,&K: V#uupiuupi) u``{session_id: status}`` from each session's LAST message row (``'empty'`` when none); one query, MAX(id) per session joined back — never scans transcripts.ra3 SELECT m.session_id, m.role, m.tool_calls IS NOT NULL AS has_tool_calls, m.finish_reason FROM messages m JOIN ( SELECT session_id, MAX(id) AS max_id FROM messages WHERE session_id IN (z[) GROUP BY session_id ) latest ON m.id = latest.max_id rrr)rrrr)r6r~rrr)rrrrstatusesr8r*s&& r/session_lifecycle_statuses/SessionSessionsMixin.session_lifecycle_statusess +00b090sSss09IcT9Imfjm (}t3 m mr1c  \WqVWVWeV V R7 wrV'd^RIHp V !W V 4VPR\ V R4 2V 4^,#)zWCount sessions with list_sessions_rich's filters so a paired "load more" total matches.) rgrhrirkrKrlrmrnrorprzSELECT COUNT(*) FROM sessions sr)rrrrrf)rrhrirKrlrnrmrgrkrorprrrs&&&&&&&&&&& r/ session_count"SessionSessionsMixin.session_count4s`!6-g+Vg'^o"7 !   F 'V D~~ ? =Z]@^?_`bhijkllr1c&<V^8dQhRS[RS[/#)r)nr+)rsrr)r.rs"r/r0rFsPP#PdPr1c @\VPRV344V8#)z[At least N sessions exist (archived included); LIMIT short-circuits session_count()'s scan.zSELECT 1 FROM sessions LIMIT ?)rr6)rrs&&r/session_count_ge%SessionSessionsMixin.session_count_geFs 4>>"BQDIJaOOr1rnrmrgc H<V^8dQhRS[RS[RS[RS[S[S[3,/#)r)rnrmrgr+)rrr,r-rs)r.rs"r/r0rJs=LL#'L@DLL c3hLr1c  \W2VR7wrEV'd^RIHpV!WV4VP4;_uu_4pVPf \ R4hVP R\VR4 R2V4P4pRRR4XU u/uF0p \V R,4\V R ,;'g^4bK2 up # +'giLM;iuup i) zV``{source: count}`` via one GROUP BY; ``exclude_children`` mirrors listing visibility.)rgrmrnrNzSessionDB connection is closedzYSELECT COALESCE(NULLIF(s.source, ''), 'cli') AS source, COUNT(*) AS count FROM sessions srzC GROUP BY COALESCE(NULLIF(s.source, ''), 'cli') ORDER BY count DESCrhcount) rrrr_conn RuntimeErrorrrfrr-rs) rrnrmrgrrrrr8r*s &$$$ r/session_count_by_source,SessionSessionsMixin.session_count_by_sourceJs !6--!    F 'V D ^^  zz!"#CDD<<"",]C"@!ABUUV\hj GKKdsCM"CG (9(9$::dKK LsAC *C> C C c<<V^8dQhRS[RS[S[S[3,/#rP)r-rMrr)r.rs"r/r0r`s( c c# c%c :J cr1c VPV4pV'gR#VPV4\VPR4;'gR4P 43#)u(is_fork_child, source) in ONE read (prompt_cache_scope needs both from the same row). Missing row → (False, ""); DB errors propagate (fail closed). ``agent/prompt_cache_scope.py`` needs both to resolve a host-declared conversation scope, and both live on the same ``sessions`` row; asking for them separately read that row twice per resolution (@teknium1 on 98811). The marker rules stay here, beside :meth:`is_explicit_fork_child`, instead of being re-implemented by the caller. See #98811. r4rh)Fr4)r_is_explicit_fork_child_rowr-r6r7)rrrs&& r/declared_scope_identity,SessionSessionsMixin.declared_scope_identity`sS"":. //8#gkk(>S>Y>YWY:Z:`:`:bbbr1c:<V^8dQhRS[S[,RS[RR/#)r) sessions_dirrr+N)rrr-)r.rs"r/r0ros'HTNPTr1c zVfR#RUu.uFq V V 2, NK ppVPVRV R2, 4VPVPR\P!V4 R244VFpVP RR7K R#uupi \dL0i;i \dK@i;i) a9Remove ``.json``/``.jsonl``, the legacy ``session_.json`` snapshot, and gateway ``request_dump__*.json``; OSError is swallowed so a filesystem hiccup never blocks a DB operation. Every historical writer name is swept because a "deleted" session's snapshot can carry plaintext secrets (#20334, #60207).N.jsonsession_ request_dump_z_*.jsonT) missing_ok)r"z.jsonl)r}rglobescapeOSErrorunlink)r rsuffixtargetsps&& r/_remove_session_files*SessionSessionsMixin._remove_session_filesns   H[\H[fZL"999H[\| E&BBC  NN<,,}T[[=TV AUVV s)B B B( cF<V^8dQhRS[S[,RS[S[,/#rra)r.rs"r/r0rs$##T#Y#4PS9#r1c V\V4p\V4p\\4FBpV'gM9\ W4pVUu.uF qwV9gK VNK ppVP V4KD ^RIHp\V4FpVP V!W44K \V4#uupi)uExpand *session_ids* to every member of their compression chains. The dashboard sessions list surfaces one row per logical conversation: compression roots are projected forward to their latest continuation, and the surfaced row carries the *tip's* id (see :meth:`list_sessions_rich`). Deleting only that tip row leaves the root behind, and the next list re-projects the root onto the previous link — the "deleted" conversation reappears (#57543). Walks compression-continuation edges in BOTH directions from the given ids: backward to the chain root, and forward through every continuation — including stale sibling continuations (e.g. ``ws_orphan_reap`` leftovers), which would otherwise be orphaned into brand-new visible top-level rows by the delete itself. The edge definition matches ``_CHAIN_STEP_SQL`` / ``get_compression_tip`` and the list-projection CTE: parent ended with ``reason='compression'``, child is not a branch / reset / delegate / tool session. Branch, reset and delegate children are deliberately NOT pulled in — a branch/reset is its own conversation, and delegates are handled by the existing cascade in the delete paths. Runs inside the caller's write transaction (*conn*). The walk is defensively bounded like ``get_compression_chain`` — ``seen`` guards cycles. )local_conversation_ids)rrNranger$rrrr;) rrrseenrrr+rr;s &&& r/_expand_compression_lineage0SessionSessionsMixin._expand_compression_lineages,; $z"A5dEG'.BwT/wHB KK ! # >:C KK.t9 :DzCs B&B&c<V^8dQhRS[RS[S[,RS[S[S[,,RS[S[S[S[S[S[S[3,,3,,RS[RS[RS[/#)r)rr expected_delete_idsexpected_display_messagesexclude_active_write_guardsinclude_compression_chainr+)r-rrrNr,rrr)r.rs"r/r0rsEEE-5d^E%d3i0E$,Dd4S>6J1J,K#LE&* E $( E  Er1c Daaaaa a V'dSPS.VSRR7^8#.o Ve \V4MRo VVV V VV3RlpSPV4pV'd\SS RSVR7^RIHp V !S4S Fp SP W*4K \V4#)u$Delete a session and its messages; delegate children cascade, branch/compression children are orphaned. Optional expected ids fence delegate drift; expected display snapshots fence transcript drift. Both checks run inside the same write transaction as deletion. With ``exclude_active_write_guards``, raises :class:`SessionActiveWriteGuardError` if the row is protected by an active turn lease or compression lock. With ``include_compression_chain=True`` the whole compression chain the session belongs to is deleted with it (root and every continuation) — the dashboard delete endpoints use this variant because their list rows carry chain-*tip* ids; deleting only that physical row would leave the rest of the chain to resurface on the next list (#57543). Default False so callers that operate on a single physical session keep the historic contract. Routing through :meth:`delete_sessions` keeps the chain-aware guard/counting semantics in one place; its return value counts the *requested* ids that existed, so ``> 0`` is exactly "the session was found".T)r rCrDNcD<aSPRS 34P4fR#^RIHpV!SS 4pS'gSe.VO\ SV4OMRpS'd(S P SV4'd\ RS R24hSeS\V48wdR#Sea\;QJd.VV 3RlSP44F 'gK RM# RM!VV 3RlSP444'dR#^RI H pV!SV4S P\SV44VF)pSPR V34SPR V34K+ SPR VUu.uFqU3NK up4S PS4S PV4R#uupi) r1NFr2z session 'zD' (or a delegate child) has an active turn lease or compression lockc3R<"TFwrSPSV4V8gxK R#5ir)_display_messages_from_conn)r covered_idexpectedrrs& r/rCSessionSessionsMixin.delete_session.._do..s-=,M(J00zBhN,Ms$'TrzHUPDATE sessions SET parent_session_id = NULL WHERE parent_session_id = ?)DELETE FROM messages WHERE session_id = ?!DELETE FROM sessions WHERE id = ?)rrvrr3r _guarded_idsrranyrrrrr executemanyr) rr3r5 target_idsrrrCrB expected_ids removed_idsrrs f r/rc0SessionSessionsMixin.delete_session.._dos||IJ=Ybbdl =%dJ7E/,2JD%C5dEBCPT +t/@/@z/R/R2 |+op'LC O,K(4=,E,K,K,M==,E,K,K,M=:: H D% (   8uE F gjmiop H3&Q   @UZB[UZc6UZB[ \  4 4T :   u %C\s' F deleterIrAr collect_retired_media)delete_sessionsrrr"hermes_state_mediarXr-rr) rrr rArBrCrDrcdeletedrXrrRrSs ff&&ff& @@r/delete_session#SessionSessionsMixin.delete_sessions* %'' <,G*.(   "$ 3F3Rs./X\   B%%c*  {8Zfr s<d#C  & &| 9G}r1c&<V^8dQhRS[RS[/#rPr+)r.rs"r/r0rsSTr1c raV3RlpVPV4pVfVPS4#\V4#)a'Abort a row this same flow just created and nobody has been admitted against (seed-copy compensation): remove it WITHOUT the retirement fence so the id can be lazily recreated. A row with any admission or worker receipt is a real session and takes the fenced :meth:`delete_session` path instead.c<VPRSS34P4'dR#VPRS34VPRS34pVP^8#)zSELECT 1 FROM session_admissions WHERE target_session_id=? UNION ALL SELECT 1 FROM worker_executions WHERE session_id=? LIMIT 1NrLrM)rrvrK)rcurrs& r/rc._dosf||MOY[eNfhhphphrs LLDzm T,,BZMRC<&&z2 2F|r1c<<V^8dQhRS[RS[S[,RS[/#)r)rr r+)r-rrrr)r.rs"r/r0rs'**#*Xd^*_c*r1c aaVV3RlpSPV4pV'd\SS.RVR7^RIHpV!S4V'dSP VS4V#)aDelete *session_id* only if it has no messages, no title and no children; check and delete share one transaction so a concurrent flush can't be lost. A row under an active turn lease or compression lock is never a candidate: the emptiness predicate reads committed state, so a row whose first turn is already leased but not yet flushed would be deleted mid-turn (#123583). A guarded row is simply not deleted (returns ``False``), like any non-empty row.c$<^RIHpSPVS.4'gV!VS4S.8wdR#VPRS34P 4pVfR#^RIHpV!VS.S.R7VPRS34SPV4R#)rr2Fa SELECT 1 FROM sessions WHERE id = ? AND title IS NULL AND NOT EXISTS ( SELECT 1 FROM messages WHERE messages.session_id = sessions.id ) AND NOT EXISTS ( SELECT 1 FROM sessions child WHERE child.parent_session_id = sessions.id ) r)expiringrMT)rr3rNrrvrrr)rr3eligiblerrrs& r/rc9SessionSessionsMixin.delete_session_if_empty.._dos <   |448I$PZ8[`j_k8k||  hj  I D:,* F LL._do..expand..\s$)asDUVZ\_D`q!D`!ss!)r>rNr,fromkeys)rrrDr3rs&r/expandASessionSessionsMixin.delete_sessions.._do..expandXs3,;;D#FFDMM)as)aabbr1rrrr)rrr~rrr3rrrNr>rrNrr4rrrrr)rrr*existingryexpanded guard_pool active_idsrmember_lineagemembersrrr3rCrDrSrrq unique_idssf @r/rc1SessionSessionsMixin.delete_sessions.._doPs/9*/E/EeQUQ]Q]78QRW8X7YYZ[]bRhjR#D R /EH < c ch'HR8R&A$&QRJ** #&% $$T:660#+C-01Q1QRVY\X]1^-_N*..s3#008^8^%@tNG[%\8^ _ _ *s 3 $,,4&+3C#008eVSE]:R'8e9TUY[b9c8e f C8#& ,4M8C*7LCC8M*&&vj'9:!(+ H D( +   8xH I#H-.u5 _`b_ccdegl I"QOQVW A"QGO .  4 4T :   x (x= u@& NsAI8;1I>1I>=J JrUNrVrWr|) rNrDr-rr"rrZrXr-) rrr rCrqrDrrcrrXrSrs f&&fff @@r/rY$SessionSessionsMixin.delete_sessions<s +*;*;*;\*;3z#s?S3X[33*;\] !# ; !; !x##C(  {8^abl^mqr^rZXY]x|.: <<d#C  & &| 9 Q]sCCCzmessage_count = 0 AND ended_at IS NOT NULL AND archived = 0 AND NOT EXISTS (SELECT 1 FROM messages WHERE messages.session_id = sessions.id)c <V^8dQhRS[/#rr&)r.rs"r/r0rseecer1c LVPRVP 24^,#)z^Count of empty, ended, non-archived sessions; ended_at guards a fresh session's first message.z$SELECT COUNT(*) FROM sessions WHERE )r_EMPTY_SESSION_WHEREr(s&r/count_empty_sessions)SessionSessionsMixin.count_empty_sessionss&~~ DTE^E^D_`abcddr1c6<V^8dQhRS[S[,RS[/#)r)r r+)rrrs)r.rs"r/r0rs(4.Cr1c aa.oVV3RlpSPV4pV'd\SSRVR7^RIHpV!S4SFpSP W4K V#)zDelete every empty, ended, non-archived session in one transaction, orphaning (not cascading) children; transcript files are swept too.c<VPRSP 24P4Uu0uF qR,kK pp^RIHpV!V\ V44pV'g^#\ V4Fap\V4pVPRV R2V4VPRV R2V4VPRV R2V4SPV4Kc SPV4\V4#uupi)rr)retire_prunablerrzrr) rrrrrr4rr~rrr)rr*rrrrrSrs& r/rc7SessionSessionsMixin.delete_empty_sessions.._dos04 01J1J0KL1hj11t991K I)${0CDK#K0.u5 hikhllmnpuv I"QOQVW A"QGO""5)1  4 4T :{# #!sC1rkrlrWrm)rr rcrrXrrSsf& @r/delete_empty_sessions*SessionSessionsMixin.delete_empty_sessionss["$  $$##C(  {=Wc d<d#C  & &| 9 r1cJ<V^8dQhRS[S[,RS[R,RS[/#)r)older_than_daysrhNr+)rrr-rs)r.rs"r/r0rs-  ' ?BTz   r1c VPRR4RVR&VP!RRVRV/VBpVFpVPVR,R4K \V4#) a<Bulk soft-hide with prune_sessions' filter surface, via set_session_archived so each lineage flips as a unit; idempotent. Returns matches. A lineage is matched through its TIP only: an old compression ancestor never qualifies on its own age, or the fan-out would hide an open, recently active continuation (#115489).r7FTlineage_tips_onlyrrhrr|) setdefaultlist_prune_candidatesrCr)rrrhfiltersr8r*s&&&, r/archive_sessions%SessionSessionsMixin.archive_sessionssf :u-'+#$))d/dRXd\cdC  % %c$i 64yr1c6<V^8dQh/S[S[,;R&#)r)_session_compact_cols_sqlr)r.rs"r/r0rOsR (}3Sr1r|)NNNNNNNNNNNNNNN)unknownNr) session_reset)NNF)NNr)z1UPDATE sessions SET model_config = ? WHERE id = ?N>r system_prompt_hashgit_metadata_generation)NNNNrFrTFFFNNFFNFFN)NrrNNF) NNNrFFFNFN))NNNFF)NFNF)[__name__ __module__ __qualname____firstlineno____doc__r staticmethodrrr#r'r.r;_ORPHAN_ADOPTION_MAX_GAP_Sr"_NON_CONTINUATION_CHILD_FILTER_SQLrErArTr\rerlr}rrrrrrrrrrrrrrrrr rrrrr#r)r3r1rCrGrbrrPrSr]rarhrp frozenset_SESSION_COMPACT_EXCLUDEDrrrr classmethodrrrrrrrrr rrrr-r7r>r\rcrnrYrrrr__annotate_func____static_attributes____classdictcell__)rs@r/rrOsuY" A A-J-J^    "IM"!%""D"'*EY)O&  SS !!2.((B* [_ 37  8  6  !! ! ! "& BF  < ! !6QW66&::RR UU <<  9= Y] 26 VZ    (QQ dd < <****, ? ?&& 13  @B"VZ dd&&.7%%N"KKbb ::!*J!04 ] ]D**Xnn-1 n "% n '+ n%)nn`CCJ4*KK[[55   :mm$PPL*/LGLL!&LL, c c* W W##JEEN$**XXX~ J ee>  g3r1r)r)r4)kanbanroneshot>r agent_errorcontent_filter) rjr r rrr5rrr3rrz, )r5r3roz/ )_delegate_fromr)r rjr r rrrr)Trr&rEloggingrrrBpathlibrtypingrrrrrrr r agent.session_activityr r r hermes_state_errorsrhermes_state_commonrrrrrrrrrrrrrrrrRrrr r~r!r"r#hermes_state_compressionr$r% getLoggerrr8r@objectrr9rIrUr]rfrrrrINTERNAL_LISTING_SOURCESrrrSESSION_STATUS_EMPTYrrr_SAME_KEY_NAMESPACE_SQLrer._UPSERT_KEEP_EXISTING_SQLr _INHERIT_SEPr_FORK_EDGE_EXCLUSION_SQLrrr|r1r/rs:   NNN=D   > *^ 6 #H66E ( %(<@(^b("(HL(gk((7<(W\($ (TX (V!H6< $9$*""LM#$["JJ'['   9$=>?((   2 N'M NUCZB[[\;])]^ N N77#7# 36    r1