i# dZddlZddlZddlZddlZddlmZddlmZm Z ddl m Z eejddZ d Zd Z dd ed e ed edede f dZd edeefdZd e edeefdZd edeefdZy)uE Genesis Persistent Context Architecture — Scatter-Gather Memory Fetch Story 2.04 — Track B scatter_gather_memory() — Concurrent 3-layer memory fetch. L1: Redis working state (task-keyed fast lookup) L2: KG entity topology (file-based JSONL scan) L3: Qdrant scar similarity (semantic/cosine search) All 3 fetches fire concurrently via asyncio.gather. Each is wrapped in asyncio.wait_for for individual timeout enforcement. On any fetch failure or timeout → that field gets None (partial result is valid). Total latency is wall-clock time across all 3 concurrent fetches. N)Path)OptionalList) MemoryContextKG_ENTITIES_DIRz./mnt/e/genesis-system/KNOWLEDGE_GRAPH/entitiesxtask_idtarget_entities intent_string timeout_msreturnc Ktj}|dz }tjtjt ||tjt ||tjt||dd{}tj|z dz}d}t||d||d||d | S7Kw) a& Scatter-gather across 3 memory layers concurrently. Fires L1, L2, and L3 fetches at the same time using asyncio.gather. Each fetch has its own asyncio.wait_for timeout so a slow layer cannot block the others beyond the shared wall-clock budget. Args: task_id: Identifier for the current agent task (L1 lookup key). target_entities: Entity names/IDs to search for in the KG (L2). intent_string: Natural-language intent used as L3 similarity query. timeout_ms: Per-fetch timeout in milliseconds (default 45 ms). Returns: MemoryContext with whatever data arrived before timeout. Any layer that failed or timed out contributes None for its field. latency_ms always records the real wall-clock elapsed time. g@@)timeoutT)return_exceptionsNc(t|try|S)z>Return result value or None on any exception (timeout, error).N) isinstance BaseException)results 3/mnt/e/genesis-system/core/memory/scatter_gather.py_safez$scatter_gather_memory.._safePs fm , rr) working_state kg_topologylearned_constraints latency_ms) time monotonicasynciogatherwait_for_fetch_redis_l1 _fetch_kg_l2_fetch_qdrant_l3r) r r r rstart timeout_sresultslatencyrs rscatter_gather_memoryr+,s0 NN EV#INN19Eo6 J)-8)L G~~%'61G GAJ''!*%!'!*-  sBC CA C cFK ddlm}tjdd}||r|nd}|j |d{}|y|j rdj |j nd}d|jd |d |jS7O#t$rYywxYww) z Fetch working state from Redis L1. Returns a human-readable summary string of the RedisL1State, or None on cache miss or any connection/import error. r) RedisL1Client REDIS_URLNz, nonezTask: z , Focus: z, Hypothesis: ) redis_l1_schemar-osgetenv get_statefocus_entitiesjoinr current_hypothesis Exception)r r- redis_urlclientstatefocuss rr$r$bs2IIk2. Iy4@&&w// =383G3G %../VU]]O$W 334 6 0 sGB!%?%E%E%G $/ &D#x/4:3E&+iic&:(- &#(>'*$)IIm.3ii 2.F%H("#3?(4!(#buTF/K L % &wH 9G>3G(GG2AGBGGG(#G>(H )G><H G GG GG% !G((G;7G>:G;;G>> H H  H  H c K|sy ddl}ddlm}tjdd}tjdd}|||r|ndd }|j |j j}td Dcgc]}t||t|zd z !}}|jd |d } | syg} | D]T} | jxsi} | jdd} | jd| jd| d| j ddVddj#| zScc}w#t$$rYywxYww)a? Fetch learned constraints from Qdrant L3 'aiva_scars' collection. Uses a deterministic hash-based pseudo-vector so this layer works without an embedding model at query time. In production, replace the hash vector with real embeddings. Returns up to 2 scar descriptions, or None on any error. Nr) QdrantClient QDRANT_URLz/https://qdrant-b3knu-u50607.vm.elestio.app:6333QDRANT_API_KEYr/r)urlapi_keyrigo@ aiva_scars)collection_name query_vectorlimitrFunknownzScar rHz (score=z.2f)zLearned Constraints: rI)hashlib qdrant_clientrir2r3sha256encodedigestrangefloatrNsearchpayloadrVrXrBscorer6r8)r rtri qdrant_url qdrant_keyr:rxivectorr)scarsr>r|rgs rr&r&se *.YY  = YY/4 ",J$  4 4 67>>@3Z  &S[) *U 2  --(    GAiio2G;;}i8D LL5bhqwwsm1E F G ($))E*:::) , sHEA?D7$D2*D7EA.D71E2D77 EEEE)-)__doc__r!rRr2rpathlibrtypingrrzero_amnesia_enveloperr3rrOrWrUrzr+r$r%r&rrrs  !0 yryy4  / /#Y// /  /l38C=8<S <hsm<F7#7(3-7r