iU[dZddlZddlZddlZddlmZmZmZddlmZddl m Z ddl m Z m Z mZmZmZddlmZddlZej(j+dee ej0j0ddlmZmZdd lmZGd d eZeGd d ZeGddZ GddZ!da"de!fdZ#ddedede fdZ$de e de fdZ%ddedede fdZ&dZ'e(dk(re'yy)am GENESIS EXECUTION LAYER ======================== The HARDWIRED execution pattern for ALL Genesis agents. ANY task entering Genesis MUST flow through this layer, which enforces: 1. RWL Swarm execution (Gemini agents as primary workers) 2. Rate Limit Maximizer (stay at 90-95% capacity) 3. Automatic task decomposition into RWL stories 4. Parallel execution where possible This is the SINGLE SOURCE OF TRUTH for task execution. Usage (ALL agents must use this): from core.genesis_execution_layer import execute_task, execute_rwl_swarm # Single task result = await execute_task("Implement feature X") # PRD/Multi-task results = await execute_rwl_swarm(prd_or_tasks) Entry Points That MUST Use This Layer: - CLAUDE.md agent briefings - GEMINI.md agent briefings - aiva_orchestrator.py - All swarm orchestrators - All API endpoints - All webhook handlers N) dataclassfieldasdict)datetime)Path)DictListOptionalAnyCallable)Enum)GeminiRateMaximizerTaskType)GeminiExecutorc(eZdZdZdZdZdZdZdZdZ y) ExecutionModezExecution modes available.singlerwl_seq rwl_swarmhybrid alpha_evolve agent_teamN) __name__ __module__ __qualname____doc__SINGLERWL_SEQUENTIAL RWL_SWARMHYBRID ALPHA_EVOLVE AGENT_TEAM5/mnt/e/genesis-system/core/genesis_execution_layer.pyrr2s#$ FNI F!LJr$rceZdZUdZeed<eed<eed<eeeefed<dZe ed<dZ e ed <d Z e ed <d Z e ed <dZeeed<dZeeed<dZeeed<y)StoryzRWL Story format.idtitle descriptionacceptance_criteriapriorityFpassesr iterationsmax_iterationsNresulterror completed_at)rrrrstr__annotations__r rr-intr.boolr/r1r2r r3r4r#r$r%r'r'<sz G Jd38n--HcFDJNC FHSM E8C="&L(3-&r$r'ceZdZUdZeed<eed<eed<eed<eed<eed<eed<e e Z e e eefed <e e Ze eed <y ) ExecutionResultzResult from execution layer.successmodestories_completedstories_failed total_tokens total_costelapsed_seconds)default_factoryresultserrorsN)rrrrr8r6rr7floatrlistrCr rr5r rDr#r$r%r:r:Ls]& M $)$$?GT$sCx. !?d3FDI3r$r:ceZdZdZdZdZdZdZfdZdZ dZ d#d e d e d e d e ee effd Zd$de fdZ d%d e d e d e de d e ee eff dZ d&deede de d e ee effdZd'de defdZd(de de d eefdZded efdZded efdZ d'deede d efdZ d)de de d ed efd!Zd ee effd"ZxZS)*GenesisExecutionLayerz The HARDWIRED execution layer for ALL Genesis operations. Every task MUST flow through here to ensure: - RWL pattern is always used - Rate limits are maximized - Swarm execution when beneficial Nr, r0c~|j%t| ||_d|j_|jS)NF) _instancesuper__new__ _initialized)cls __class__s r%rMzGenesisExecutionLayer.__new__ls3 == !GOC0CM).CMM &}}r$c|jryt|_td|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_tt j"j"dz dz |_|j$j"j'ddd|_y)NT)use_rate_maximizerrgdatazexecution_layer.jsonl)parentsexist_ok)rNrrate_maximizerrexecutor _qwen_client _qwen_enabled _kimi_fast_kimi_standard _kimi_max _kimi_enabledactive_swarm_sizetotal_executionsr?r@r__file__parentlog_pathmkdir)selfs r%__init__zGenesisExecutionLayer.__init__rs    13&$? !!"!"# !X--44v=@WW  ""4$"? r$c|j ddlm}||_|jS|jS#t$r d|_YywxYw)zLazy load Qwen client.Nr)UnifiedQwenClientF)rX core.qwenrg ImportErrorrY)rdrgs r%_get_qwen_clientz&GenesisExecutionLayer._get_qwen_clientsV    $ 7$5$7!   t    %*" s8A  A prompt system_prompt max_tokensreturncLK|j}|r |jsy |j|||d{}|j|j|j |j ddS74#t$r'}|jddt|iYd}~yd}~wwxYww)a$ Execute a task using Qwen/AIVA Ollama. Use for: - Very long context tasks (>50k tokens) - AIVA validation requests - Memory consolidation tasks Returns: Dict with response, tokens, and timing, or None if Qwen unavailable N)rkrlrmqwen)text tokens_usedexecution_timemodelbackend qwen_errorr3) rjrYgeneraterqrrrsrt Exception_logr5)rdrkrlrmclientresponsees r%execute_with_qwenz'GenesisExecutionLayer.execute_with_qwens"&&(T// #__+%-H ! '33"*"9"9!!     IIlWc!f$5 6 s> B$A1A/3A1.B$/A11 B!:BB$B!!B$tiercd|}t||d ddlm}t||||t||dS#t$r d|_YywxYw)z,Lazy load Kimi K2.5 client for a given tier._kimi_Nr) KimiSwarm)rtF)getattrcore.kimi_swarmrsetattrrir])rdr~attrrs r%_get_kimi_clientz&GenesisExecutionLayer._get_kimi_clientsbv 4t $ , 5dID$9:tT4(( %*" s;A Ac K|jsy|j|}|sy|js|jdd|iy |j |||d{}|j s |jd|j |dy|j|j|j|j|jd|dS7l#t$r(}|jdt||dYd}~yd}~wwxYww) u Execute a task using Kimi K2.5 (Moonshot AI). Routing guide: - tier="fast" (8K) — short tasks, rapid Q&A, classification - tier="standard" (32K) — typical Genesis stories, code gen, research - tier="max" (128K)— very long documents, multi-file analysis, deep research Native PARL: 100 sub-agents per call, 1500 tool calls. Returns: Dict with response, tokens, cost, and timing, or None if Kimi unavailable Nkimi_not_configuredr~)rksystemrm kimi_errorr3r~kimi)rqrr cost_estimatersrtrur~)r]r_is_configuredry execute_asyncr;r3rqr?rrsrtrxr5)rdrkrlrmr~rzr{r|s r%execute_with_kimiz'GenesisExecutionLayer.execute_with_kimis(!!&&t,$$& II+fd^ < #11$%2H ## ,(..$(OP! '44!)!7!7"*"9"9!! $  IIlc!fd$C D sNAD C!C"/CD;C DC DC<7D<DDtasks max_workersc ^K|jsy|j|}|sy|js|jdd|iy |j ||d{}|j |j Dcgc]1}|j|j|j|jd3c}|j|j|j|j|jd|d S7cc}w#t$r(}|jdt!||d Yd}~yd}~wwxYww) u Execute a parallel Kimi swarm — up to 100 concurrent agents. Args: tasks: List of {"prompt": ..., "system": ..., "max_tokens": ...} tier: "fast" | "standard" | "max" max_workers: Parallel threads (Kimi supports 100 native PARL) Returns: Dict with texts list, aggregate tokens/cost, or None on failure Nkimi_swarm_not_configuredr~)rr)rqtokenscostr; kimi_swarm) texts responsesr?r@rA success_count failure_countrur~kimi_swarm_errorr)r]rrryswarm_execute_asyncrrrqr?rr;r@rArrrxr5)rdrr~rrzr2rr|s r%execute_kimi_swarmz(GenesisExecutionLayer.execute_kimi_swarms "!!&&t,$$& II1FD> B !55E{5[[F$--VVq~~qcdclclm!' 3 3$//#)#9#9!'!5!5!'!5!5'  \  II(CFD*I J sTAD- C9 C2!C9>6C44=C91D-2C94C99 D*D% D-%D**D-eventrSctjj||xsid}t|jd5}|j t j|dzdddy#1swYyxYw)zLog execution events.) timestamprrSa N)rnow isoformatopenrbwritejsondumps)rdrrSentryfs r%ryzGenesisExecutionLayer._log2sh"113JB  $-- % . GGDJJu%, - . . .s (A22A;taskcontextcd|d|d}|jj|dd}|jstd|dd |d d d gd gS |j}d|vr'|j dd j dd}n*d|vr&|j dd j dd}t j|j}t|Dcgc]l\}}t|jdd|d zd|jdd|jdd|jdg|jddnc}}Scc}}w#t j$rtd|dd |d d d gd gcYSwxYw)z Decompose a task into RWL stories using Gemini. This is the KEY pattern - every complex task becomes stories. zOYou are a Genesis RWL (Ralph Wiggum Loop) task decomposer. TASK TO DECOMPOSE: z CONTEXT: aT Decompose this into discrete, verifiable stories. Each story must: 1. Be completable in a single focused session 2. Have clear acceptance criteria 3. Be independently verifiable Return JSON array of stories: ```json [ { "id": "STORY-001", "title": "Short descriptive title", "description": "Detailed description of what to implement", "acceptance_criteria": [ {"description": "Criterion 1", "verification": "How to verify"}, {"description": "Criterion 2", "verification": "How to verify"} ], "priority": 1 } ] ``` Return ONLY valid JSON, no other text. architecturerk task_typermz STORY-001NdzTask completedmanual)r* verificationr(r)r*r+r-z```jsonz```rr(STORY-03dr)r*r+r-r,) rWexecute_optimizedr;r'r{splitrloadsstrip enumerategetJSONDecodeError) rdrrdecomposition_promptr2r{ stories_dataiss r%decompose_to_storiesz*GenesisExecutionLayer.decompose_to_stories<s $  '  *>00'$1  ~~4Cj 5EW_%`$a   HH$#>>)4Q7==eDQG("#>>%0399%@C::hnn&67L&l3 AquuTVAaC9#56%%, !mR 8().CR(HUU:q1    ## 4Cj 5EW_%`$a   s& BEA1EEE+FFstoryc |xjdz c_dj|jDcgc]}d|jd|c}}d|jd|j d|d}|j j|d d }|jrNd |jvr@d |_ |j|_ tjj|_n&|j xsd|_|j|_ |xj"|j$z c_|xj&|j(z c_|Scc}w)zy Execute a single RWL story with self-verification. This is the ATOMIC unit of work in Genesis. rrz- r*z)# GENESIS RWL STORY EXECUTION ## Story: z ## Description z ## Acceptance Criteria a ## Instructions 1. Implement the solution completely 2. Verify against EACH acceptance criterion 3. Report PASS or FAIL for each criterion 4. If ALL pass, include: TASK_COMPLETE 5. If ANY fail, explain what needs fixing ## Response Format ``` CRITERION 1: [PASS/FAIL] - [explanation] CRITERION 2: [PASS/FAIL] - [explanation] ... IMPLEMENTATION: [Your implementation details] STATUS: [TASK_COMPLETE or TASK_INCOMPLETE] ``` Execute now.code_generation r TASK_COMPLETETzDid not complete all criteria)r/joinr+rr)r*rWrr;r{r.r2rrrr4r3r?rrr@r)rdrc criteria_textexecution_promptr2s r% execute_storyz#GenesisExecutionLayer.execute_storysA A ..# }a() *#   ;;- >00#'1  >>o@EL!??EL!)!9!9!;E  ,,I*IEK!??EL V/// 6/// m# sEc|Ktjjd|j|d{S7w)z"Async wrapper for story execution.N)asyncioget_event_looprun_in_executorr)rdrs r%execute_story_asyncz)GenesisExecutionLayer.execute_story_asyncs9++-== $$$e    s 3<:<stories max_parallelcpKtj}|xs |j}|jj\}}|jj |jj }|j dd}t||dzt|}td|}|jdt|||dg} g} g} t|d}td t||D]} || | |z} | Dcgc]}|j|}}tj|d {}|D]}|j r| j#|ns|j$|j&krI|j|d {}|j r| j#|n#| j#|n| j#|| j#t)|tj|z }|jd t| t| |d t+t| d k(t,j.t| t| |j0|j2|| | Dcgc]}|j4s|j4c} Scc}w7v7$cc}ww)z Execute stories as a SWARM with parallel Gemini agents. This is the PREFERRED execution mode for multi-story work. rpm_availablerrIr swarm_start)r swarm_sizecapacityc|jSN)r-)rs r%z9GenesisExecutionLayer.execute_rwl_swarm..s  r$)keyrNswarm_complete) completedfailedelapsed r;r<r=r>r?r@rArCrD)timeDEFAULT_SWARM_SIZErVcan_execute_researchget_available_capacityget_best_modelrminlenmaxrysortedrangerrgatherr.appendr/r1rr:rrr?r@r3)rdrr start_time can_researchreasonr available_rpmeffective_swarm_sizerrrCrbatchrr batch_results retry_resultrrs r%execute_rwl_swarmz'GenesisExecutionLayer.execute_rwl_swarmsxYY[ #>t'>'>  $22GGI f&&==    . . 0  ! _c: "<"1Dc'lS"1&:; -7|. "   &:;q#g,(<= .AAa"667ECHHT--e4HEH")..%"88M& .<<$$U+%%(<(<<)-)A)A%)H#HL#**!((6 l3MM%(ve}- . .,))+ * "Y&k%  K1$((!)nv;**#%+7qwwAGG7  5I8$I68sJDJ6J&J65J+6AJ6 J. C3J6>J1J1J6.J61J6 force_modechKtj}|xjdz c_|jdd|ddi|r|}nj|j||}t ||j k\rt j}n/t |dkDrt j}nt j}|t jk(r|jj|dd}t|j||jrdnd |jrd nd|j|jtj|z d |j ig|j"r|j"g Sg S|t jk(r|j||}g}g} |D]B} |j%| } | j&r|j)| 2| j)| Dtt | d k(|t |t | |j*|j,tj|z || zD cgc] } t/| c} | D cgc]} | j"s| j"c} S|j||}|j1|d{Scc} wcc} w7w) aJ THE MAIN ENTRY POINT for all Genesis task execution. This method: 1. Analyzes task complexity 2. Decomposes into RWL stories if needed 3. Executes via swarm (preferred) or sequential 4. Maximizes rate limit utilization throughout ALL agents MUST use this method. r task_startrNgeneralrrrr{r)rr_ryrrMIN_TASK_COMPLEXITY_FOR_SWARMrrrrrWrr:r;rrrr{r3rr.rr?r@rr) rdrrrrr<rr2rrrexecutedrs r% execute_taskz"GenesisExecutionLayer.execute_task$sc"YY[  " ,ds 45 D//g>G7|tAAA$..W!$33$++ ='' ']]44#5F #'-~~!1$*NNq#//!// $ j 8$foo67)/ ~  <>  ]11 1//g>GIF  ,--e4??$$X.MM(+  ,#F q("%i."6{!..?? $ j 8,5,>?q?)/;A177;  //g>G//88 8@; 9s0H9J2;J& J2J+%J+3.J2!J0"J2c @|jj}i} ddlm}|d|d|dd}|j |j |j|j|j|j|j|d S#t$rddi}Y`wxYw) zGet execution layer status.r) kimi_statusfaststandardr)rrrr3zkimi_swarm not importable) initializedr_r?r@rate_limit_utilization best_modelrecommendations kimi_k2_5) rVget_utilization_reportrrrxrNr_r?r@total_capacity_usedr r )rd utilizationr _kimi_statuss r% get_statusz GenesisExecutionLayer.get_statuszs))@@B   A C$V,(4#E*K ,, $ 5 5 --//&1&E&E%00*::$   A"$?@K AsB BB)Nr)r)Nrr)rrIrr)rN) rrrrrKrMAX_SWARM_SIZErrMrerjr5r7r rr r}rrr rryr'rrrr:rrrr __classcell__)rPs@r%rHrHZsIN$%! !: !" $$$ $ $sCx. ! $L )S )" 444 4  4 $sCx. ! 4r .Dz.. . $sCx. ! .`.#.T.PPsPDKPd>5>U>@ u  !N eN N   N f$( T9T9T9" T9  T9l DcN r$rHrnc.t tatS)z+Get the singleton execution layer instance.)_execution_layerrHr#r$r%get_execution_layerrs02 r$rrcVKt}|j||d{S7w)z3Execute a task through the Genesis Execution Layer.N)rr)rrlayers r%rrs'  !E##D'2 22 2s )')rcdKt}t|Dcgc]l\}}t|jdd|dzd|jdd|jdd|jdg|jd d  n}}}|j |d {Scc}}w7 w) z Execute stories as an RWL swarm.r(rrrr)rr*r+r-r,rN)rrr'rr)rrrr story_objectss r%rrs  !Eg&  Aq uuTVAaC9-.%%$mR0 !&;R @UU:q)   M ((7 77  8sB0A1B( B0#B.$ B0c@tjt||S)z%Synchronous wrapper for execute_task.)rrunr)rrs r%execute_task_syncrs ;;|D'2 33r$cddl}|jd}|jdgd|jdtd |j }t }|j d k(r1|j}ttj|d y|j d k(ritdtd}td|jtd|jjtd|jy|j dk(r\|j s tdyt|j }ttjt#|d tyy)NrzGenesis Execution Layer)r*command)statustestexecute)choicesz--taskzTask to execute)typehelpr!)indentr"zTesting execution layer...z*What is 2 + 2? Reply with just the number.z Success: zMode: zTokens: r#zError: --task required)r(default)argparseArgumentParser add_argumentr5 parse_argsrr rprintrrrr;r<valuer?rr)r*parserargsrr!r2s r%mainr2s5  $ $1J $ KF  +HI s1BC    D  !E ||x!!# djj*+   *+"#OP &..)*+ v{{(()*+ ,,-./  "yy * + "499- djj3?@ #r$__main__r))rrrr dataclassesrrrrpathlibrtypingrr r r r enumr syspathinsertr5r`racore.gemini_rate_maximizerrrcore.gemini_executorrrr'r:rHrrrrrr2rr#r$r%r=s!> 0066 3tH~,,3345D/D  ' '  '  4 4  4y y z23S3333 8T$Z 8O 8 4C4#44 A: zFr$