i)u(SrSSKrSSKrSSKrSSKJrJrJr SSKJr SSK J r SSK J r J r JrJrJr SSKJr SSKr\R(R+S\"\ "\5R0R055 SSKJrJr SS KJr SS KJr S r!"S S\5r#\"SS55r$\"SS55r%"SS5r&Sq'S\&4Sjr(SS\S\S\%4Sjjr)S\ \ S\%4Sjr*SS\S\S\%4Sjjr+Sr,\-S:Xa\,"5 gg!\"a S r!Sr Nf=f) 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)GeminiExecutor) KimiExecutorTFc0\rSrSrSrSrSrSrSrSr Sr S r g ) ExecutionMode:zExecution modes available.singlerwl_seq rwl_swarmhybrid alpha_evolve agent_teamN) __name__ __module__ __qualname____firstlineno____doc__SINGLERWL_SEQUENTIAL RWL_SWARMHYBRID ALPHA_EVOLVE AGENT_TEAM__static_attributes__r1E:\genesis-system\core\genesis_execution_layer.pyrr:s#$ FNI F!LJr(rc\rSrSr%Sr\\S'\\S'\\S'\\\\4\S'Sr \ \S'S r \ \S 'S r \ \S 'S r\ \S'Sr\\\S'Sr\\\S'Sr\\\S'Srg)StoryDzRWL Story format.idtitle descriptionacceptance_criteriapriorityFpassesr iterationsmax_iterationsNresulterror completed_atr)rrrrr str__annotations__r rr2intr3boolr4r6r7r r8r9r'rr(r)r+r+Dsz G Jd38n--HcFDJNC FHSM E8C="&L(3-&r(r+c\rSrSr%Sr\\S'\\S'\\S'\\S'\\S'\ \S'\ \S '\ "\ S 9r \ \\\4\S '\ "\ S 9r\ \\S 'S rg)ExecutionResultTzResult from execution layer.successmodestories_completedstories_failed total_tokens total_costelapsed_seconds)default_factoryresultserrorsrN)rrrrr r=r;rr<floatrlistrIr rr:r rJr'rr(r)r?r?Ts]& M $)$$?GT$sCx. !?d3FDI3r(r?cN^\rSrSrSrSrSrSrSrU4Sjr Sr S r S*S \ S \ S \ S \\\ \44SjjrS \S4SjrS+S \ S \\ S \ S\ S \\\ \44 SjjrS,S\\ S\ S\ S \\ S \ S \\\ \44 SjjrS-S\ 4SjjrS.S \ S \ S \ S\ S \\\ \44 SjjrS/S\\S\ S\ S \\\ \44SjjrS0S\ S\4SjjrS1S\ S\ S \\4SjjrS \S \4S!jrS \S \4S"jrS0S#\\S$\ S \4S%jjrS2S\ S\ S&\ S \4S'jjr!S \\ \44S(jr"S)r#U=r$$)3GenesisExecutionLayerbz 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 Nr1 r5c>URc%[TU] U5UlSURlUR$)NF) _instancesuper__new__ _initialized)cls __class__s r)rTGenesisExecutionLayer.__new__ts3 == !GOC0CM).CMM &}}r(cUR(ag[5Ul[SS9UlSUlSUlSUlSUlSUl SUl SUl [Ul SUlSUlSUlSUl[%[&5R(R(S- S- UlUR*R(R-SSS9 SUlg)NT)use_rate_maximizerrgdatazexecution_layer.jsonl)parentsexist_ok)rUrrate_maximizerrexecutor _qwen_client _qwen_enabled _kimi_fast_kimi_standard _kimi_max _kimi_enabled_kimi_executorKIMI_EXECUTOR_AVAILABLE_kimi_executor_enabledactive_swarm_sizetotal_executionsrErFr__file__parentlog_pathmkdirselfs r)__init__GenesisExecutionLayer.__init__zs    13&$? !!"!:>&=#"# !X--44v=@WW  ""4$"? r(cURcSSKJn U"5UlUR$UR$![a SUlgf=f)zLazy load Qwen client.Nr)UnifiedQwenClientF)r` core.qwenrt ImportErrorra)rprts r)_get_qwen_client&GenesisExecutionLayer._get_qwen_clientsV    $ 7$5$7!   t    %*" s9A  A prompt system_prompt max_tokensreturnc\# UR5nU(aUR(dgURUUUS9IShvN nURURUR UR SS.$N4![a'nURSS[U505 SnAgSnAff=f7f)z 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)ryrzr{qwen)text tokens_usedexecution_timemodelbackend qwen_errorr8) rwrageneraterrrr Exception_logr:)rpryrzr{clientresponsees r)execute_with_qwen'GenesisExecutionLayer.execute_with_qwens"&&(T// #__+%-H ! '33"*"9"9!!     IIlWc!f$5 6 s@*B,A8A63A85B,6A88 B)B$B,$B))B, _KimiExecutorcUR(dgURc"[(dSUlg[5UlUR$)z1Lazy-load the KimiExecutor (Moonshot direct API).NF)rhrfrgrros r)_get_kimi_executor(GenesisExecutionLayer._get_kimi_executorsA**    &**.3+"//D """r(rc z^^^^^# UR5mT(dgTR5(dURSST05 g[R"5nUR SUUUUU4Sj5IShvN nUR (d URSURTS.5 gURURURURURSURURS.$N![a(nURS[!U5TS.5 SnAgSnAff=f7f) u Execute a single task via KimiExecutor (Moonshot API direct). Use this instead of execute_with_kimi when you want to bypass OpenRouter and call Moonshot's API directly with the provided MOONSHOT_API_KEY. Model routing: model="fast" → moonshot-v1-8k ($0.15/1M — short tasks) model="standard" → moonshot-v1-32k ($0.15/1M — typical stories) model="max" → moonshot-v1-128k ($0.60/1M — long documents) Returns: Dict with response, tokens, cost, timing — or None if unavailable. Nkimi_executor_not_configuredrc(>TRTTTTS9$)N)ryrrzr{)execute)r_r{rryrzsr)BGenesisExecutionLayer.execute_with_kimi_executor..s!((!"/) )r(kimi_executor_errorr8r kimi_executor)rr cost_estimaterrr prompt_tokenscompletion_tokens)r is_configuredrasyncioget_event_looprun_in_executorrAr8rrrrrrrrr:) rpryrzr{rloopr7excr_s ```` @r)execute_with_kimi_executor0GenesisExecutionLayer.execute_with_kimi_executors***,%%'' II4w6F G ))+D//F>> /6<4D2D;3ADD;D D8D3.D;3D88D;tasks max_workersc ^^^^^^ # UR5m T (dgT R5(dURSST05 g[R"5nUR SU UUUUU4Sj5IShvN nUR URVs/sH=nURURURURURS.PM? snURURURUR UR"STS. $Ns snf![$a(n URS['U 5TS .5 Sn A gSn A ff=f7f) u Execute a parallel swarm via KimiExecutor (Moonshot API direct). Up to 50 concurrent workers. Tasks returned in submission order. Args: tasks: List of prompt strings. model: "fast" | "standard" | "max" max_workers: Concurrency ceiling (max 50). system_prompt: Shared system message. max_tokens: Max tokens per task. Returns: Dict with texts list, aggregate tokens/cost — or None on failure. N"kimi_executor_swarm_not_configuredrc*>TRTTTTTS9$)N)rrrzr{r)execute_tasks_parallel)r_r{rrrzrsr)rCGenesisExecutionLayer.execute_kimi_executor_swarm..1s$77"/) + 8r()rtokenscostrArkimi_executor_swarm) texts responsesrErFrG success_count failure_countrrkimi_executor_swarm_errorr)rrrrrrsuccessful_responsesrIrrrrArrErFrGrrrr:) rprrrrzr{r swarm_resultrrr_s ````` @r)execute_kimi_executor_swarm1GenesisExecutionLayer.execute_kimi_executor_swarmsD.**,%%'' II:We B !55E5[[F$---VVq~~qcdclclm-!' 3 3$//#)#9#9!'!5!5!'!5!5'  \  II(CFD*I J sTAD<D+D,D 9D=D?D<DD D9D4/D<4D99D<eventr[c[R"5R5UU=(d 0S.n[URS5nUR [ R"U5S-5 SSS5 g!,(df  g=f)zLog execution events.) timestamprr[a N)rnow isoformatopenrmwritejsondumps)rprr[entryfs r)rGenesisExecutionLayer._logs_"113JB  $-- % GGDJJu%, -& % %s )A99 BtaskcontextcSUSUS3nURRUSSS9nUR(d[SUSS US S S ./S S9/$URnSU;a'UR S5S R S5SnO,SU;a&UR S5S R S5Sn[ R"UR55n[U5VVs/sHiupx[URSSUS -S35URSS5URSS5URS/5URSS5S9PMk snn$s snnf![ Ra [SUSS US S S ./S S9/s$f=f)zp 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. architecturery task_typer{z STORY-001NdzTask completedmanual)r/ verificationr-r.r/r0r2z```jsonz```rr-STORY-03dr.r/r0r2r1) r_execute_optimizedrAr+rsplitrloadsstrip enumerategetJSONDecodeError) rprrdecomposition_promptr7r stories_dataiss r)decompose_to_stories*GenesisExecutionLayer.decompose_to_storiess $  '  *>00'$1  ~~4Cj 5EW_%`$a   HH$#>>)4Q7==eDQG("#>>%0399%@C::hnn&67L&l3 4DAuuTVAaC9#56%%, !mR 8().CR(HUU:q1 4   ## 4Cj 5EW_%`$a   s& BE#A0EEE)F F storyc U=RS- slSRURVs/sHnSURSU53PM sn5nSURSUR SUS3nUR RUS S S 9nUR(aQS UR;aAS Ul URUl [R"5R5UlO+UR =(d SUlURUl U=R"UR$- slU=R&UR(- slU$s snf)za 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)r4joinr0rr.r/r_rrArr3r7rrrr9r8rErrFr)rprc criteria_textexecution_promptr7s r) execute_story#GenesisExecutionLayer.execute_story!sF A ..# .}a() *.#   ;;- >00#'1  >>o@EL!??EL!)!9!9!;E  ,,I*IEK!??EL V/// 6/// m# sEc~# [R"5RSURU5IShvN $N7f)z"Async wrapper for story execution.N)rrrr)rprs r)execute_story_async)GenesisExecutionLayer.execute_story_asyncas8++-== $$$e    s 4=;=stories max_parallelc# [R"5nU=(d URnURR5upEURR URR 55nUR SS5n[X'S-[U55n[SU5nURS[U5UUS.5 /n /n /n [USS9n[S [U5U5GHn XX-n U Vs/sHoRU5PM nn[R"U6IS hvN nUHnUR (aU R#U5 OyUR$UR&:aNURU5IS hvN nUR (aU R#U5 O#U R#U5 OU R#U5 U R#[)U55 M GM [R"5U- nURS [U 5[U 5US .5 [+[U 5S :H[,R.[U 5[U 5UR0UR2UU U Vs/sH"nUR4(dMUR4PM$ snS 9 $s snfGNGN5s snf7f)zu Execute stories as a SWARM with parallel Gemini agents. This is the PREFERRED execution mode for multi-story work. rpm_availablerrPr swarm_start)r  swarm_sizecapacitycUR$N)r2)rs r)r9GenesisExecutionLayer.execute_rwl_swarm..s r()keyrNswarm_complete) completedfailedelapsed rArBrCrDrErFrGrIrJ)timeDEFAULT_SWARM_SIZEr^can_execute_researchget_available_capacityget_best_modelrminlenmaxrsortedranger rgatherr3appendr4r6rr?rr#rErFr8)rpr r  start_time can_researchreasonr available_rpmeffective_swarm_sizerrrIrbatchrr batch_results retry_resultrrs r)execute_rwl_swarm'GenesisExecutionLayer.execute_rwl_swarmgshYY[ #>t'>'>  $22GGI &&==    . . 0  ! _c: "<"1Dc'lS"1&:; -7|. "   &:;q#g,(<=Aa67ECHH%--e4%EH")..%"88M&<<$$U+%%(<(<<)-)A)A%)H#HL#**!((6 l3MM%(ve}-'>,))+ * "Y&k%  K1$((!)nv;**#%+7VqwwGAGGV7  5I8$I68sJDKK K8K9AKKC>KK +K ; KK K force_modec# [R"5nU=RS- slURSSUSS05 U(aUnOkURX5n[ U5UR :a[ RnO0[ U5S:a[ RnO[ RnU[ R:XaURRUSSS9n[URUUR(aSOS UR(aS OSURUR[R"5U- S UR 0/UR"(aUR"/S 9 $/S 9 $U[ R:XGaURX5n/n/n UHIn UR%U 5n U R&(aUR)U 5 M8U R)U 5 MK [[ U 5S :HU[ U5[ U 5UR*UR,[R"5U- X-V s/sHn [/U 5PM sn U V s/sH!oR"(dMU R"PM# sn S 9 $URX5nUR1U5IShvN $s sn fs sn fN7f) a  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_startrNgeneralrrrrr)rrjrrr"MIN_TASK_COMPLEXITY_FOR_SWARMrr#r"r!r_rr?rArrrr8rr3r'rErFrr0) rprrr2r(rBr r7rrrexecutedrs r) execute_task"GenesisExecutionLayer.execute_tasks_"YY[  " ,ds 45 D//>G7|tAAA$..W!$33$++ ='' ']]44#5F #'-~~!1$*NNq#//!// $ j 8$foo67)/ ~  <>  ]11 1//>GIF --e4??$$X.MM(+ !#F q("%i."6{!..?? $ j 8,5,>?,>q,>?)/;A77;  //>G//88 8@; 9s0IKK(K.K K *KKKcFURR5n0nSSKJn U"S5U"S5U"S5S.n0nUR 5nU(aUR 5nOS S S .nURURURURURURURUUS U(aSU;aS OSURS5(aS OSS.S. $![a SS0nNf=f![anS[U50nS nANS nAff=f)zGet execution layer status.r) kimi_statusfaststandardr#)r=r>r#r8zkimi_swarm not importableFznot configured or import failed) availabler*Nactive configurednot_configured)geminikimi_swarm_openrouterkimi_executor_moonshot) initializedrjrErFrate_limit_utilization best_modelrecommendations kimi_k2_5rbackends)r^get_utilization_reportrr<rr get_statusr:rUrjrErFtotal_capacity_usedrHrIr)rp utilizationr< _kimi_statuskimi_executor_statuskexrs r)rM GenesisExecutionLayer.get_status s7))@@B   A C$V,(4#E*K " 7))+C'*~~'7$5:Fg'h$  ,, $ 5 5 --//&1&E&E%00*::$1"5@WT_E_el6J6N6N|6\6\(br   A"$?@K A 7$+SX#6  7s.C+'C?'C?+C<;C<? D  DD )rUrerfrhrbrdrcr`rarir_rmr^rFrjrE)Nr)Nrr>)r>rPNr)r>)Nrr>)r>rPrr)rN)%rrrrr rRrMAX_SWARM_SIZEr7rTrqrwr:r<r rr rrrr rrrrrr+rrr r?r0rr9rMr' __classcell__)rWs@r)rNrNbsIN$%! !B !" $$$ $ $sCx. ! $P #H_$= #(, 55 }5 5  5 $sCx. ! 5t '+ ?Cy?? ?  } ?  ? $sCx. !?F )S )" 444 4  4 $sCx. ! 4r .Dz.. . $sCx. ! .`.#.T.PPsPDKPd>5>U>@ u  !N eN N   N f$( T9T9T9" T9  T9l* DcN* * r(rNr|c0[c [5q[$)z+Get the singleton execution layer instance.)_execution_layerrNrr(r)get_execution_layerrY>s02 r(rrcT# [5nURX5IShvN $N7f)z3Execute a task through the Genesis Execution Layer.N)rYr9)rrlayers r)r9r9Gs$  !E##D2 22 2s (&(r cb# [5n[U5VVs/sHiup#[URSSUS-S35URSS5URSS5URS/5URS S 5S 9PMk nnnUR U5IS hvN $s snnfN 7f) z Execute stories as an RWL swarm.r-rrrr.rr/r0r2r1rN)rYrr+rr0)r r[rr story_objectss r)r0r0Ms  !Eg& 'DA uuTVAaC9-.%%$mR0 !&;R @UU:q)  ' ((7 77  8sB/A0B' B/"B-# B/c@[R"[X55$)z%Synchronous wrapper for execute_task.)rrunr9)rrs r)execute_task_syncr`]s ;;|D2 33r(cSSKnURSS9nURS/SQS9 URS[SS 9 UR 5n[ 5nUR S :Xa/UR5n[[R"US S 95 gUR S :Xai[S5 [S5n[SUR35 [SURR35 [SUR35 gUR S:Xa_UR (d [S5 g[UR 5n[[R"[#U5S [S95 gg)NrzGenesis Execution Layer)r/command)statustestr)choicesz--taskzTask to execute)typehelprc)indentrdzTesting execution layer...z*What is 2 + 2? Reply with just the number.z Success: zMode: zTokens: rzError: --task required)ridefault)argparseArgumentParser add_argumentr: parse_argsrYrbrMprintrrr`rArBvaluerErr)rkparserargsr[rcr7s r)mainrscs5  $ $1J $ KF  +HI s1BC    D  !E ||x!!# djj*+   *+"#OP &..)*+ v{{(()*+ ,,-./  "yy * + "499- djj3?@ #r(__main__rT).r rrr dataclassesrrrrpathlibrtypingrr r r r enumr syspathinsertr:rkrlcore.gemini_rate_maximizerrrcore.gemini_executorrcore.kimi_executorrrrgrvrr+r?rNrXrYr9r0r`rsrrr(r)rsL> 0066 3tH~,,3345D/@" D  ' '  '  4 4  4U  U  r23S3333 8T$Z 8O 8 4C4#44 A: zFW#MsD DD