+ iHj-Rt^RIt^RIt^RIHtHt^RIHt]P!] 4t Rt Rt RRlt RRR lltR R ltR R ltRRltRtRtRRRlltRRltRRltRRltRRltR#)uRotation-stable logical cache scope for prompt_cache_key derivation. Legacy compression rotation mints a new physical ``session_id`` mid-conversation, moving it into a fresh cache bucket. ``resolve_prompt_cache_scope()`` maps the physical id to the ROOT of its compression lineage — NOT ``get_conversation_root`` (the Portal-attribution walk), which would collapse /branch children and delegate trees into one id. ``/new`` starts a fresh scope; fork children (branch, delegate, tool-tagged) are isolated. Hosts minting one id per RESPONSE declare the conversation via ``gateway_session_key``, which wins over the lineage walk and is hashed to ``gwk_`` (it embeds platform/chat/user identifiers). N)AnyOptional)base_url_hostname_prompt_cache_scope_memogwk_cRV^8dQhR\R\R\\,/#) session_id session_dbreturn)strrr)formats"=/home/ubuntu/.hermes/hermes-agent/agent/prompt_cache_scope.py __annotate__rs%  c s x} c"VfR#VPV4p\ T\ \ 34'd2T'd*T^,p\ T\4'd T'dT#R# \d\PRRR7R#i;i)zRCompression-lineage root of *session_id*, or None (tolerates test-double results).Nz&prompt-cache scope lineage walk failedTexc_info)get_compression_lineage Exceptionloggerdebug isinstancelisttupler )r r lineageroots&& r _lineage_rootrsz44Z@'D%=))gqz dC TK   = MsA(("B Bc jV^8dQhR\R\R\R\\,R\/#)ragentr r row_sourcer )rr r)r s"rrr(s855 55-05>Fsm55rcVf[V'dSVeOVPV4pV'd3\ VP R4;'gR4P 4MRpV'dV#\VRR4p^RIH p\ V!V44P 4# \d\PRRR7RpLi;i) aThe ``sessions.source`` this agent's conversation is recorded under. ``row_source``: the row's value if already read (``""`` = read, none; ``None`` = look it up). Before the row lands, use the SAME resolver persistence uses, not ``agent.platform``: they diverge under ``HERMES_SESSION_SOURCE`` and the declared scope is memoized at once, so both sides of a ``/new`` would otherwise hash the same scope. Nz#declared-scope source lookup failedTrsourceplatform)session_source_for) get_sessionrrrr getstripgetattragent.session_sourcer%)rr r r rowr$r%s&&&& r _agent_sourcer,(sjZ-C ((4C>AS*00b1779b uj$/H7 !(+ , 2 2 44  LL>L NC sB$CCcHV^8dQhR\R\R\R\/#)r session_keyr"r r )r r)r s"rrr@s) > ># >s > >PS >rc\VRR4p\V4'gR#V!W4pVfR#\\V44#)aDurable generation for *session_key*'s current conversation (``""`` if none). The declared key survives ``/new``, so hashing it alone would reuse one scope across conversations. The counter advances with each reset boundary, independent of prunable rows and wall-clock; compression does not advance it. The declared key names a chat and deliberately survives `/new` and policy resets. See #79017, #86733. latest_conversation_boundaryNr#)r)callabler int)r.r"r reader generations&&& r_conversation_generationr5@sDZ!? FF F   ,J#2=S_)==rcFV^8dQhR\R\\,/#rrr rrr )r s"rrrPs6/6/s6/x}6/rc\VRR4p\V\4'dVP\4'dV#\\VRR4;'gR4P 4pV'd\VRR4'dR#\\VRR4;'gR4p\VRR4pRpRpV'dKVeG\VR R4p\ V4'd V!V4wrMVPV4pV'dR#\WWF4p Ve\W)V4pV RV RV 2p \P!V PRRR74P!4R,p \ V 2# \d\PR R R 7R#i;i \d\PR R R 7R#i;i)uHost-declared logical conversation scope (``gwk_``), or None. Hashes ``(source, gateway_session_key, generation)``. None (fall back to the physical id) when no key is declared, for a background-review fork (``_persist_disabled``), for an explicit fork child, and on any DB error (fail closed rather than merge a fork onto its parent's key). The one sanctioned exception is a same-model cache-parity fork (#109964): its whole purpose is prefix parity with the parent, yet ``_persist_disabled`` + ``_session_db=None`` made both resolvers key it into a different bucket (one cold ~full-context request per review). ``build_cache_parity_fork`` stamps the parent's ALREADY-RESOLVED scope as ``_inherited_cache_scope`` (no DB access from the fork). Only a ``gwk_`` value is a declared scope; a physical lineage root stays out of the affinity header so the fork publishes exactly what its parent publishes (None → consumers fall back to the conversation root). _inherited_cache_scopeN_gateway_session_keyr#_persist_disabledFr _session_dbdeclared_scope_identityz declared-scope fork check failedTrz%declared-scope generation read failed|zutf-8replace)errors:NN)r)rr startswith_DECLARED_SCOPE_PREFIXr(r1is_explicit_fork_childrrrr,r5hashlibsha256encode hexdigest) r inheritedkeysiddbr4r identityis_forkr"carrierdigests & rdeclared_conversation_scoperRPs 7>I)S!!i&:&:;Q&R&R ge3R8>>B ? E E GC '%!4e<< ge\4066B 7C  t ,BJ $J r~ r#I)S!!iu00 ge\4066B 7C   t ,B $ C 5*d +D$3t9>d1gnu1g.. &u - G Gs1GD KKCE 2:8KU)S)S  E:| 4 5 ((   sD-- D;:D;z::cHV^8dQhR\R\R\R\/#)rprovidermodelbase_urlr rbool)r s"rrrs/WWWCW3WPTWrcD\T;'gR4P4P4R9dR#\\T;'gR44R8XdR#\T;'gR4P4P4P \ 4#)agTrue when the cache key selects ONE server-side slot per conversation. xAI (``xai``/``xai-oauth``, ``api.x.ai``, or Grok via OpenRouter ``x-ai/grok-*``) pins its prompt cache to the server picked by ``x-grok-conv-id`` / ``prompt_cache_key``: two divergent request streams under one key evict each other. Anthropic, DeepSeek and Gemini caches are content-addressed and OpenAI's ``prompt_cache_key`` only routes over a prefix match, so the shared scope (#109964) stays a win there. Only the OpenRouter profile reads ``cache_scope_id`` for the sticky header; other aggregators fronting Grok change only the body key. r#Tzapi.x.ai>xai xai-oauth)r r(lowerrrCGROK_AGGREGATOR_MODEL_PREFIXES)r^r_r`s&&&ris_slot_keyed_cache_routerhsw 8>>r  "((*.BBX^^,-; u{{  ! ! # ) ) + 6 67U VVrc0V^8dQhR\R\/#)rr[r ra)r s"rrrsDDsDtDrcD\V\4;'d \V9#)z?True when *scope* is a fork-derived scope (``::``).)rr FORK_SCOPE_SEPARATOR)r[s&ris_fork_cache_scoperls eS ! C C&:e&CCrc<V^8dQhR\R\R\/#)rrr[r rT)r s"rrrs! 1 13 1s 1s 1rc .\VRR4pV'd\V\4'd V'gV#\\VRR4R^4^8dV#\\VRR4\VRR4\VRR44'gV#V \ V 2#) a``::`` for a tagged fork on a slot-keyed route, once the fork's OWN compaction committed: before it the fork extends the parent's prefix (warm read, #109964); after it the rewritten stream would evict the parent's xAI slot. Read per call, so fallbacks re-evaluate._prompt_cache_fork_tagNcontext_compressorcompression_countr^r#r_r`)r)rr rhrk)rr[tags&& rrVrVs %14 8C  3,,C wu2D9;NPQRUVV $z2&w(CWUT^`bEc   W)*3% 00rcFV^8dQhR\R\\,/#r7r8)r s"rrrsCHSMrcl\V4# \d\PRRR7R#i;i)z=Never-raising variant of :func:`declared_conversation_scope`.z-declared conversation scope resolution failedTrN)rRrrrrs&r declared_conversation_scope_safervs5*511  Dt Ts "33cFV^8dQhR\R\\,/#r7r8)r s"rrrs38C=rc\V4;'gR# \d\PRRR7R#i;i)uONever-raising variant of :func:`resolve_prompt_cache_scope` (None = use the physical id). At turn_context an exception inside ``set_runtime_main(...)`` would skip the whole binding. Returns None on any failure (or when there is no scope). Consumers treat None/empty as "fall back to the physical session_id", so a resolution failure degrades to pre-#79017 behavior instead of blocking the caller — important at turn_context's call site, where an exception raised inside the ``set_runtime_main(...)`` argument list would otherwise skip the whole runtime binding, not just the cache scope. Nz$prompt-cache scope resolution failedTr)r\rrrrus&rresolve_prompt_cache_scope_saferys=)%088D8  ;d Ks"==)N)z x-ai/grok-z xai/grok-)r#)__doc__rFloggingtypingrrutilsr getLogger__name__rrWrDrr,r5rRr\rkrgrhrlrVrvryrrrsx  #   8 $ '   50 > 6/r)>"=W"D 1 r