iE5dZddlZddlZddlZddlZddlmZmZddlmZddl m Z edZ e dz Z e dz d z Z e d z Ze d z Zd Zd edefdZd ededefdZd edefdZddededefdZdefdZdefdZdZedk(reyy)uD GENESIS EVOLUTION ENGINE (GEN-028) ===================================== Wires failure detection into the Genesis evolution cycle. Every failure that flows through `on_failure_detected()` is: 1. Logged to logs/failures.jsonl (durable audit trail) 2. Diagnosed — lesson extracted from the error context 3. Axiom generated — a reusable rule to prevent recurrence 4. Written to KNOWLEDGE_GRAPH/axioms/evolution_axioms.jsonl This engine is the bridge between the failure detector and the living knowledge base. It implements RULE 14: "Failure Is Our Greatest Ally." Relationship to existing engines: - evolution_engine.py — deep 4-step diagnosis (Diagnose/Root-Cause/Pre-mortem/Evolve) - genesis_evolution_protocol.py — cross-session learning protocol (EvolutionProtocol class) - THIS FILE — lightweight hook-based failure wiring for GEN-028 Usage: from core.genesis_evolution_engine import on_failure_detected, record_lesson, get_evolution_stats on_failure_detected({ "task_id": "RAI-009", "error": "Telnyx 422 — assistant clone failed", "context": "POST /ai/assistants/{id}/clone returned 422 Unprocessable" }) # CLI: python3 genesis_evolution_engine.py --stats python3 genesis_evolution_engine.py --failure '{"task_id":"X","error":"timeout"}' N)datetimetimezone)Path)Optionalz/mnt/e/genesis-systemlogsKNOWLEDGE_GRAPHaxiomszfailures.jsonlzevolution_axioms.jsonlc`tjddtjddy)NT)parentsexist_ok)LOGS_DIRmkdir KG_AXIOMS_DIR6/mnt/e/genesis-system/core/genesis_evolution_engine.py _ensure_dirsr4s% NN4$N/t4r failure_eventreturnct|jdd}t|jdd}t|jdd}d|dg}|r'|dd j}|jd ||r'|dd j}|jd ||j }d |vsd |vr|jdnd|vs d|vsd|vsd|vr|jdnd|vsd|vr|jdnd|vsd|vsd|vr|jdnd|vsd|vsd|vr|jdnd|vsd |vsd!|vr|jd"ngd#|vsd$|vsd%|vr|jd&nId'|vsd(|vr|jd)n/d*|vsd+|vsd,|vr|jd-n|jd.d/j |S)0u Derive a human-readable lesson from a failure event. Uses structured heuristics to extract meaning without requiring an LLM call at log time — keeping this path fast and side-effect free. errortask_idunknowncontextzTask z failedNxz with error: z Context: timeout timed outzDLesson: Implement retry with exponential backoff for this operation.401403 unauthorized forbiddenzCLesson: Validate API credentials and token scopes before execution.422 unprocessablezHLesson: Validate request payload schema against API spec before sending. rate limit429too manyzILesson: Apply rate limiting / back-pressure before hitting external APIs.importmodule no modulezOLesson: Verify all dependencies are installed and importable in the target env. connectionrefused unreachablezJLesson: Add health-check / circuit-breaker before dependent service calls.jsondecodeparsezHLesson: Always validate and sanitise external data before deserialising.keykeyerrorzHLesson: Use .get() with defaults; never assume external dict keys exist.nonenonetype attributezGLesson: Guard against None values before attribute access or iteration.zFLesson: Add specific error handling and logging for this failure path.z )strgetrstripappendlowerjoin)rrrrparts short_error short_ctx error_lowers r_extract_lessonr@9s   !!'2. /E-##Iy9:G-##Ir23GWIW % &E DSk((*  |K=12DSM((*  y ,-++-KK;+#= [\ + +!5;9VZeitZt Z[ + K!? _`  $(< k@Y `a [ H $;{k?Y fg  $ [(@MU`D` ab ; (k"9W =S _` + {!: _` ; * ";{k?Y ^_ ]^ 99U rlessonc^t|jddj}d|vsd|vryd|vs d|vsd|vsd |vry d |vsd |vry d|vsd|vsd|vryd|vsd|vsd|vryd|vsd|vsd|vryd|vsd|vsd|vryd|vsd|vry d!|vsd"|vsd#|vry$|jd%d&}d'|d(S))u Synthesise a concise, reusable axiom from the lesson. Axioms are written as imperative rules — short, memorable, actionable. rrrrz[ALWAYS retry time-sensitive operations with exponential backoff (base 1s, max 30s, jitter).rr r!r"zUALWAYS validate API credentials and required scopes at task start, not mid-execution.r#r$zPALWAYS schema-validate request payloads against the API contract before sending.r%r&r'zWALWAYS implement back-pressure and rate limiting before calling external APIs at scale.r(r)r*z_ALWAYS verify import availability in a try/except at module load, fail fast with clear message.r+r,r-zWALWAYS wrap external service calls in a circuit breaker; degrade gracefully on failure.r.r/r0zTALWAYS wrap JSON parsing in try/except and log raw input on failure for post-mortem.r2r1zOALWAYS use dict.get(key, default) and assert required keys at input boundaries.r3r4r5zYALWAYS guard against None before attribute access; use Optional typing and early returns.rrzIALWAYS add explicit error handling for the failure mode observed in task .)r6r7r:)rrArrs r_generate_axiomrDjs  !!'2. / 5 5 7EE[E1l %5E>^u-D W\H\f %?e3a  %5.J%4Gh U h%/;%3Gp  )u"4 8Nh 5H-E1Ae u ` 5J%/;%3Gj##Iy9Z[bZccdeerc tdtjjddj }t |}t ||}tjtjj}||jddt|jddt|jddt|jd d|jd d |||d }ttd d5}|j!t#j$|dzddddtjjddj ||jdd|||d}tt&d d5}|j!t#j$|dzddd|S#1swYxYw#1swY|SxYw)a8 Primary hook: called whenever a failure is detected anywhere in Genesis. Performs: 1. Assigns a unique failure_id 2. Extracts a lesson from the failure context 3. Generates a reusable axiom 4. Persists to logs/failures.jsonl 5. Writes axiom to KNOWLEDGE_GRAPH/axioms/evolution_axioms.jsonl Args: failure_event: dict with at minimum {"task_id": str, "error": str} Optional keys: "context", "component", "severity" Returns: The full enriched failure record that was persisted. zFAIL-Nrrrrr componentseveritymedium) failure_idrrrrGrHrAaxiom_generated timestampautf-8encoding AX-axiom_idsource_failure_idsource_task_idaxiomrA generated_at)ruuiduuid4hexupperr@rDrnowrutc isoformatr7r6openFAILURES_LOG_PATHwriter.dumpsEVOLUTION_AXIOMS_PATH)rrJrArWr]failure_recordf axiom_records ron_failure_detectedrhs$N))"1-33567J ] +F M6 2E ,,x|| $ . . 0C! $$Y :]&&w34}((B78**;;<!%%j(;  N w 731  >*T123 $**,**2A.44678''++IyA L #S7 ;1q  <(4/01 331 s(G (G GG!sourcectdtjjddj d|||t j tjjd}ttdd5}|jtj|dzddd|S#1swY|SxYw) ac Directly append a lesson (and derived axiom) to the evolution axioms log. Use this when a lesson is known upfront without a specific failure event. Args: lesson: The lesson string to record. source: Where this lesson came from (e.g. "manual", "review", task ID). Returns: The axiom record that was appended. rRNrFrSrMrNrOrQ)rrYrZr[r\rr]rr^r_r`rdrbr.rc)rArirgrfs r record_lessonrksN$**,**2A.44678!  X\\2<<> L #S7 ;1q  <(4/01 1 s (B77Cchtg}tjr[ttdd5}|D]:}|j }|s |j t j|< dddg}tjr[ttdd5}|D]:}|j }|s |j t j|< dddi}|D],}|jdd}|j|ddz||<.td |D}td |D}|r|d nd} t|t||||| d S#t j$rYHwxYw#1swYxYw#t j$rYwxYw#1swYxYw) ai Count lessons learned and axioms generated from failures. Returns: { total_failures_logged: int, total_axioms_generated: int, axioms_from_failures: int, axioms_from_manual: int, severity_breakdown: dict, most_recent_failure: dict | None } rrNrONrHrIrc3DK|]}|jddywrUNrnr7.0rMs r z&get_evolution_stats.. s[QAEE:M4N4Zq[  c3DK|]}|jddywrprqrrs rrtz&get_evolution_stats.. sU1!%%8K2L2TQUru)total_failures_loggedtotal_axioms_generatedaxioms_from_failuresaxioms_from_manualseverity_breakdownmost_recent_failure) rraexistsr`stripr9r.loadsJSONDecodeErrorrdr7sumlen) failuresrfliner r|f_recsevrzr{ most_recents rget_evolution_statsrsNH! #S7 ; !q !zz|!  4(89  ! !F##% 'w ? !1 !zz|! djj&67  ! ! "Eii H-"4"8"8a"@1"D3E[&[[UUU"*(2,K"%X"%f+ 400*  3 //! !  ! !$ //! !  ! !s_F $E(1F$F(>$F"F((E?;F>E??FF F%"F($F%%F((F1statsctdtd|dtd|dtd|dtd|d |d rtd |d |d r|d }td |dd|dtdt|dddtdt|dddtdt|dddtd|dty)Nz' === GENESIS EVOLUTION ENGINE STATS ===z Failures logged : rxz Total axioms generated: ryz - from failures : rzz - manual lessons : r{r|z Severity breakdown : r}z Most recent failure : [rJz] rz Error : rPz Lesson : rAdz Axiom : rKz Time : rL)printr6)rmrfs r _print_statsrs8 45 &u-D'E&F GH &u-E'F&G HI &u-C'D&E FG &u-A'B&C DE !" *51E+F*GHI "#)* -c,.?-@3y>BRST c#g,/4567 c#h-0#6789 c#&7"89$3?@AB c+./01 GrcBtjd}|jddd|jddd |jd d d |jdddd|j}|jrN t j |j}t}tdt j|d|jrDt|j|j}tdt j|d|j s|js#|jst#}t%|yyy#t j$r-}td|tjdYd}~d}~wwxYw)NuCGenesis Evolution Engine — wire failures into the knowledge graph) descriptionz--stats store_truezPrint evolution stats)actionhelpz --failureJSONzIProcess a failure event. JSON string e.g. '{"task_id":"X","error":"msg"}')metavarrz--lessonLESSONzRecord a manual lesson/axiomz--sourceSOURCEmanualz+Source label for --lesson (default: manual))rdefaultru(ERROR: Could not parse failure JSON — rnzFailure processed: )indent)rizLesson recorded: )argparseArgumentParser add_argument parse_argsfailurer.rrrsysexitrhrcrArkrirrr)parserargseventerecordrecrs rmainr0st  $ $YF  ,=TU  Z   +   :     D || JJt||,E%U+ $TZZq%A$BCD {{DKK < "4::c!#<"=>? zz$,,t{{#%U0;,##  rsB '+, & 008; //%(@@5 .4.C.bf4fff>5t55p#s$:9T9@  $'T zFr