+ iHjAfRt^RIHt^RIHt^RIHt^RIHt^RI H t H t H t H t HtHt^RIHtHtHtRtRt]!]]04tR tR tR tR tR t]!RRRRR]]]]]]]]0 4],tRtRRltRRlt RRlt!]!RRRRRR]04t"R R!lt#R"R#lt$R$R%lt%R&R'lt&R(R)lt'R*t(R+R,lt)R-R.lt*R/R0lt+]],3]]-3]].3]],33t/R1R2lt0R3R4/R5R6llt1R7R4/R8R9llt2R:R;lt3R<R=lt4R>R?lt5R@RAlt6RBRClt7RDRElt8]!RF] ],] 3,RG7t9RRH/RIRJllt:RRH/RKRLllt;RH#)Mzic:\RT;'gR44#)zXThe union of ``data_use`` over *messages*: what the model receiving them must guarantee.c3"TFDp\V\4'gKVP\4;'gRFq"xK KF R#5i)Nr ) isinstancergetDATA_USE).0mrs& r" 'data_use_requirement..;s=h1*Q2HQRSRWRWX`RaRgRgegRgQQRgQsAAAr ) frozenset)rs&r"data_use_requirementr09s hBh hhr$c$V^8dQhRRRRRR/#)rmessageMutableMapping[str, Any]requires list[str]rNoner )r!s"r"r#r#>s'qq4q qdqr$cV'gR#\V4V\&VPR4p/\V\4'dTM/C\\V4/CVR&R#)zMark a tool message with its requirement. The ``display_metadata`` copy is the durable one: that column already rides every writer, branch and compaction copy, and replay lifts it back (SessionDB).Nr)listr)r(r'dict)r2r4metadatas&& r"stamp_data_user;>sU XGH{{-.H"p*Xt2L2LhRT"pW_aefnao"pG r$c V^8dQhRRRR/#)rr2r3rr6r )r!s"r"r#r#Hs55355r$cVPR4p\V\4'd=VP\4'd \ V\,4V\&R#R#R#)zURestore a replayed row's ``data_use`` key from its durable ``display_metadata`` copy.rN)r(r'r9r)r8)r2r:s& r" lift_data_user>HsH{{-.H(D!!hll8&<&< (!34'=!r$_anthropic_content_blocksreasoning_details extra_contentreasoning_opaquereasoning_textbedrock_content_blocksc V^8dQhRRRR/#)rmsgMapping[str, Any]rr )r!s"r"r#r#Us VV$5V:KVr$c\PV4'dV#VP4UUu/uFwrV\9gKWbK upp#uuppi)zY*msg* itself when it carries no persistence-only field, else a shallow copy without them.)PERSISTENCE_ONLY_MESSAGE_FIELDS isdisjointitems)rFkvs& r"without_persistence_fieldsrNUsD&11#66  YY[ U[TQA5T,TDAD[ UU Us AAcV^8dQhRR/#)rrstrr )r!s"r"r#r#\s#r$c*\4P#)zYA fresh durable id (message or tool-call occurrence): random, never derived from content.)rhexr r$r"mint_uidrS\s 7;;r$c V^8dQhRRRR/#)rvaluerrr5r )r!s"r"r#r#asrrCrIrr$c |\\PR\V\4'dTMR444#)zSThe unique non-empty string uids of a live list, in order; anything else is ``[]``.c3j"TF)p\V\4'gKV'gK%VxK+ R#5iN)r'rP)r*us& r"r-uid_list..cs%p*RAWabcehWianoaa*Rs 33 3r )r8r9fromkeysr'rUs&r"uid_listr]as.  p:eT3J3J%PR*Rpp qqr$c V^8dQhRRRR/#)rrFrGr Optional[str]r )r!s"r"r#r#fs99.9=9r$cpVP\4p\V\4'd V'dV#R#)zThe dict's ``message_uid`` when it is a non-empty string, else ``None`` (never coerced: an int or a blank would be a bug upstream of the write, not an identity).N)r( MESSAGE_UIDr'rPrFuids& r"message_uid_or_nonerdfs+ ''+ CS#&&338D8r$c V^8dQhRRRR/#)rrFr3rrPr )r!s"r"r#r#ms  3  r$cH\V4pVf\4;q\&V#)asThe dict's ``message_uid``, minting one (``mint_uid``) when it carries none. Minted ONCE per logical message, at its first insert, and stamped on the caller's dict so every later insert of that dict (compaction generation, rotation handoff, replace) writes the same uid. Never derived from content, timestamp or tool-call ids: two distinct messages may share all three. )rdrSrarbs& r"stamp_message_uidrgms' c "C {!)++ Jr$$compaction_inflight_task_restatementc V^8dQhRRRR/#)rrFr3rr6r )r!s"r"r#r#stt#;ttr$cvVPR4p/\V\4'dTM/C\R/CVR&R#)rTNr(r'r9INFLIGHT_TASK_RESTATEMENT)rFr:s& r"mark_inflight_restatementrms8ww)*Hsj4.H.H(bsSlnrsCr$c V^8dQhRRRR/#)rrFrGrr9r )r!s"r"r#r#s#4r$cVPR4pVPR4'dRR/M/p\V\4'd'VP\4'd \R/VR&V#)zThe compaction-provenance fields replay keeps (summary flag, restatement flag), else ``{}``. A proactive prune re-persists the replayed view, so a dropped flag would get the row stamped on the next replay.r_compressed_summaryTrk)rFr:fieldss& r"scaffolding_replay_fieldsrrsaww)*H47GGG#'==#9^#9CHLLQ\D]=]CC#9^^x^*2&'_^s 7C4C4c$V^8dQhRRRRRR/#)rintorGextrarr9r )r!s"r"r#r#s#09Jtr$c\V4pVP4F0wr4W29d"\W#,4\V4,MTW#&K2 V#)a,Union two ``_tool_call_uids`` maps without losing an occurrence. Folding two assistant turns that reuse a provider id (llama.cpp-style constant ids) leaves both calls in ``tool_calls``; the id then maps to every occurrence's uid, in call order, as a list. Provider ids themselves are never rewritten.)r9rK_uid_occurrences)rrmergedcall_idrcs&& r"merge_tool_call_uidsrsF$ZF W^Wh*6?;>Ns>SSnq& Mr$c V^8dQhRRRR/#)rrUrrr8r )r!s"r"r#r#s??C?D?r$cJ\V\4'd \V4#V.#rX)r'r8r\s&r"rrs$UD114;>w>r$c$V^8dQhRRRRRR/#)ruidsrG tool_callszlist[Mapping[str, Any]]rr9r )r!s"r"r#r#s$  (9 G^ cg r$c aa^RIHo\VV3RlV44p\V4pVP 4FEwopV^8gK\ VP S4;p\4'gK8V.V,VS&KG V#)ae*uids* with every provider id this row names more than once spelled out as one uid per occurrence. A single response that repeats an id shares ONE uid (its results carry it, so every call stays paired); before a fold appends another turn's occurrences, the shared uid must fill each of this row's slots or the appended uids would align with the wrong calls.)coalesce_tool_call_idc3L<"TFpS!V4;o'gKSxK R#5irXr )r*tcrrs& r"r-0per_occurrence_tool_call_uids..s$\zAVWYAZ6Zg6ZWWzs$ $)agent.message_sanitizationrrr9rKr'r(rP)rrcountsexpandedcountrcrrs&& @@r"per_occurrence_tool_call_uidsrsn A \z\ \FDzH ,,. 19488G+<$.sO+!h7ghgsNr ) rrrr(r/rrr'r9r8lenrP)rrrrrcallsnamedrr occurrencerrrcnths&& r"index_tool_call_uidsrsX7@}}\7R7X7XVX7X Y7X'+ ,7XE Y OO OE '4  == (D dD ! ! J '+hhw c4 (2w(Ca(G GCW%!CHn#($C c3  CC#!$g$ L# ZsEc$V^8dQhRRRRRR/#)rrr tool_call_idrrr_r )r!s"r"r#r#s#  !9  Q^ r$c^RIHpV'd\V\4'd V'gR#V!V4F pVP V4pV'gKVu# R#)z[The uid an indexed assistant dict minted for ``tool_call_id`` (any variant), else ``None``.tool_result_id_variantsN)rrr'rPr()rrrrrcs&& r"resolve_tool_call_uidrsEB  <55\*<8ii  3J9 r$c(V^8dQhRRRRRRRR/#) rrz list[dict] tool_indexintownersr9rr_r )r!s"r"r#r#s)dWdr$c>W,PR4p\V\4'd V'gR#^RIHp\ V!V44p\ V^, RR4FpW,p\V\4'gK#VPR4R8XdR#VPR4R8wdKTVP\V44;pf/p \W4V 3;q\V4&VwrVPV 4'dK\W4u# R#)anResolve a tool-result dict's uid from the nearest preceding assistant dict in ``messages`` that named its ``tool_call_id`` (the cross-flush case: the assistant row landed in an earlier batch). ``owners`` memoizes each assistant's (named variants, uid index) across one flush's results, so K parallel results of one assistant cost O(K) variant work instead of O(K^2).rNrroleuserrr) r(r'rPrrsetranger9idrrJr) rrrrrresult_variants prior_indexpriorentryrrs &&& r"tool_call_uid_from_historyrs '++N;L lC ( ( B1,?@OZ!^R4 %%&&  99V  & 99V  + ZZ5 * *E 3E)=e)KU(S SE2e9%   % %e , , $U995 r$_Message)boundNc$V^8dQhRRRRRR/#)rr2rrOptional[float]rr )r!s"r"r#r#.s(      r$cRVPR4fVf \4MTVR&V#)zAttach a creation timestamp without replacing source-provided time. Gateway adapters can supply the platform event time; all other callers use the local wall clock. Returns the same mapping for use at append sites. r)r( wall_time)r2rs&$r"stamp_message_timestampr.s+{{;'.7.?y{Y  Nr$c(V^8dQhRRRRRRRR/#)rrz list[Any]r2rrrrr )r!s"r"r#r#=s0    r$c<VP\WR74V#)z-Stamp and append one live transcript message.)r)appendr)rr2rs&&$r"append_messager=s OO+GIJ Nr$)<__doc__ __future__r collectionsrrruuidrtypingrrrr r r &agent.conversation_compression_archiver r rDB_ROW_SNAPSHOT CANONICAL_ROWr/REPAIR_BOOKKEEPING_FIELDSMERGED_TURN_PREFIXrarrrrIr)r0r;r>UNPRICED_REPLAY_FIELDSrNrSr]rdrgrlrmrrrvrPr8r9r{r~rrrrrrrrrrrr r$r"rsB""HHrr% % &FG+  1 # "+."4iAY&;^].0DF ## i q5#$?ATVe$68HJbdl$noV r 9  Ct 0 &s+.CT-J^]aLbertwdxy# e 3]b32? : : :^CH%= > "& "& r$