qi*fZ%SrSSKrSSKrSSKrSSKrSSKJrJr SSKJr SSK J r SSK J r J r JrJr SSKJr \ "\5R&R&S- r\"\5 S rS S S S S S S .rSSS.SSS.SSS.S.r\ \\ \\44\S'S rSrSrSrSr Sr!S1r"1Skr#\"SS55r$\"SS55r%"SS5r&Sq'\\&\S 'S!\&4S"jr(S#\S!\$4S$jr)S%\\S!\%4S&jr*S!\+4S'jr,\-S(:Xa'SSK.r.\,"5r/\.R`"\/(aSOS)5 gg!\a Nf=f)*a GENESIS KIMI EXECUTOR ====================== Moonshot AI Kimi K2.5 as a Genesis execution backend. Uses Moonshot's OpenAI-compatible API directly (not via OpenRouter). Base URL: https://api.moonshot.cn/v1 Models: moonshot-v1-8k, moonshot-v1-32k, moonshot-v1-128k Same interface as gemini_executor: execute_task_sync() + execute_tasks_parallel(). Model routing: - moonshot-v1-8k (short tasks, rapid Q&A, classification) $0.15/1M tokens - moonshot-v1-32k (typical Genesis stories, code gen) $0.15/1M tokens - moonshot-v1-128k (long documents, multi-file, deep research) $0.60/1M tokens Usage: executor = KimiExecutor() result = executor.execute_task_sync("What is 2 + 2?") print(result.response) # Parallel swarm results = executor.execute_tasks_parallel([ "Analyse revenue pipeline", "Draft outreach email for TradiesVoice", "Research competitor pricing", ]) for r in results: print(r.response) Author: Genesis System Version: 1.0.0 N) dataclassfield)datetime)Path)AnyDictListOptional) load_dotenvz.envzhttps://api.moonshot.cn/v1moonshot-v1-8kmoonshot-v1-32kmoonshot-v1-128k)8k32k128kfaststandardmax333333?inputoutputg333333?)r r rMOONSHOT_PRICING2 g?gN@>rc\rSrSr%Sr\\S'\\S'\\S'\\S'\ \S'\ \S'\\S 'S r \ \\S 'S r \\S 'S r \\S'S\4SjrSrg )ExecutionResult]z Unified result from Kimi execution. Mirrors the GeminiResponse pattern so the two executors are interchangeable in the Genesis Execution Layer. successresponsemodel tokens_used cost_estimateexecution_time task_completeNerrorr prompt_tokenscompletion_tokensreturncUR$N)r&selfs 'E:\genesis-system\core\kimi_executor.py__str__ExecutionResult.__str__qs }})__name__ __module__ __qualname____firstlineno____doc__bool__annotations__strintfloatr,r r-r.r5__static_attributes__r8r7r4r#r#]s_ MM JE8C=M3sr7r#c\rSrSr%Sr\"\S9r\\ \ S'Sr \ \ S'Sr \\ S'Sr\\ S 'Sr\ \ S 'Sr\ \ S '\S \\4S j5r\S \\4Sj5r\S \4Sj5rSrg)KimiSwarmResultuz+Aggregate result from a parallel swarm run.)default_factoryresultsr total_tokens total_costelapsed_seconds success_count failure_countr/cXURVs/sHoRPM sn$s snf)z9All response texts (including failures as empty strings).)rHr&r3rs r4 responsesKimiSwarmResult.responsess"%)LL1Lq L111s'c~URVs/sH!oR(dMURPM# sn$s snf)zOnly successful response texts.)rHr%r&rPs r4successful_responses$KimiSwarmResult.successful_responsess*%)LL>LqII  L>>>s::c URS:H$)Nr)rNr2s r4 all_successKimiSwarmResult.all_successs!!Q&&r7r8N)r9r:r;r<r=rlistrHr r#r?rIrArKrBrLrMrNpropertyr@rRrUr>rXrCr8r7r4rErEus5%*4%@GT/ "@L#J OU M3M3 24922?d3i??'T''r7rEc\rSrSrSrSS\4S\\S\S\4Sjjr \ S \\4S j5r S \ 4S jr S r\ S \S\S\S \4Sj5r\ S\S \4Sj5rS!S\S \\S\\S\S\S \4 SjjrS"S\\S \\S\\S\S\S\\S \4SjjrS\S \4SjrS\S\S S4SjrS \\\44SjrS \\\44SjrS rg)# KimiExecutoruD Direct Moonshot API executor for Genesis. Provides the same interface as GeminiExecutor: - execute_task_sync(task) — synchronous single call - execute_tasks_parallel(tasks) — parallel swarm execution Thread-safe; safe to instantiate multiple times (each instance holds its own OpenAI client and usage counters). Nrapi_key default_model max_workerscHU=(d UR5Ul[RU[5Ul[ U[5Ul[S5Ul URRRSSS9 SUl SUlSUlSUlg)Nz0E:/genesis-system/data/kimi_executor_usage.jsonlT)parentsexist_okrrJ) _load_api_keyr_MOONSHOT_MODELSget DEFAULT_MODELr`minMAX_CONCURRENT_WORKERSrarusage_log_pathparentmkdir total_callsrIrK_client)r3r_r`ras r4__init__KimiExecutor.__init__s 6$"4"4"6 ,00 N{,BC"#UV ""(((E r7r/cSH<n[RRUS5R5nU(dM:Us $ g)z9Load API key from environment (prefers MOONSHOT_API_KEY).)MOONSHOT_API_KEY MOONSHOT_KEYN)osenvironrgstrip)varkeys r4reKimiExecutor._load_api_keys:8C**..b)//1Cs 8r7c,[UR5$)z(Return True if the API key is available.)r>r_r2s r4 is_configuredKimiExecutor.is_configuredsDLL!!r7cURc!SSKJn U"UR [ S9UlUR$![an[ S5UeSnAff=f)z2Lazy-load and return the OpenAI-compatible client.Nr)OpenAIz5openai package not installed. Run: pip install openai)r_base_url)roopenair ImportError RuntimeErrorr_MOONSHOT_BASE_URL)r3rexcs r4 _get_clientKimiExecutor._get_clients] <<  ) " *DL|| "K s; A AAr'r-r.cb[RUSSS.5nUS- US-US- US--$)z,Return estimated USD cost for a single call.rri@Brr)rrg)r'r-r.pricings r4_estimate_costKimiExecutor._estimate_costsJ#&&u.MN Y &''*: : 9,0AA B r7taskcR[UR55nUS:agUS:agg)u Auto-select model based on task length. Heuristic: < 2 000 words → 8k (cheapest) 2 000–8 000 → 32k > 8 000 → 128k (long context) i@rir r )lensplit)r word_counts r4_select_model_for_task#KimiExecutor._select_model_for_tasks-&  %  $r7prompt system_prompt max_tokens temperaturec UR5(d#[SSU=(d URSSSSSS9$U(a[R X"5OUR U5n/nU(aUR SUS.5 UR S US.5 [R"5nS n [[5GHGn UR5n U RRRUUUUS 9n [R"5U- n U RnU(a UROSnU(a UR OSnU(a UR"OSnUR%XoU5nU R&SR(R*=(d SnS U;n[S UUUUU UUUS9 nU=R,S- slU=R"U- slU=R.U- slUR1UUS S5 Us $ [R"5U- n [SSUSSU SU S9$![2Gan[5U5n [7[7USS 5SS 5nU[8;=(d SU R;5;=(d SU ;nU[<;=(d6 U=(d- SU R;5;=(d SU R;5;nU(a U [S- :XaS nA M[?[@SU --[B5nU(a [EUS5n[RF"U5 S nAGM|S nAff=f)u Execute a single prompt with exponential-backoff retry on rate limits. Args: prompt: The user prompt / task description. model: Model key ("fast", "standard", "max") or full name. If None, auto-selected from prompt length. system_prompt: Optional system message. max_tokens: Maximum output tokens. temperature: Sampling temperature (0–1). Returns: ExecutionResult with response and cost metadata. FrurrJz7MOONSHOT_API_KEY not set. Add to E:\genesis-system\.env)r%r&r'r(r)r*r+r,system)rolecontentuserN)r'messagesrr TASK_COMPLETET) r%r&r'r(r)r*r+r-r.xr& status_codez rate limit429timeout connectiong@)$r}r#r`rfrgrappendtimerange MAX_RETRIESrchat completionscreateusager-r.rIrchoicesmessagerrnrK _log_usage Exceptionr@getattrRATE_LIMIT_CODESlowerRETRYABLE_CODESriRETRY_BASE_DELAYRETRY_MAX_DELAYrsleep)r3rr'rrrresolved_modelr start_time last_errorattemptclientr&elapsedrr-r.rIcosttextr+resultrr is_rate_limit is_retryabledelays r4executeKimiExecutor.executes,!!##"1t11!"#Q      -,,V4  *,  OOX-H IF;<YY[ $( [)G? "))+!;;2299(%) + :))+ 2 7< 3 3! ?DE$;$;!!5:u11 **>J[\''*22::@b /4 7 ( !( ,"&#*"/"/&7   A% !!\1!4't 5 M*D))+ * "  7 " X %gc:t&DmUYZ  #33+#z'7'7'99+ *  ?2:$: J$4$4$66:$z'7'7'99 $w+/'A,W =O sOE 5!!1 "s!EH11 L>tasksc t^^^^^^^T(d [5$[U=(d TR[[ T55m[ R "5nS[ [4UUUUUUU4Sjjn[R"5n U R5(a\SSK n U RRSS9n U R[RU"55n U R!5n SSS5 OU R#U"55n [ R "5U- n['SW 55n['SU 55n['S U 55n[ U 5U- n[U UUUUUS 9$!,(df  Nx=f![$a [R"U"55n Nf=f) aO Execute multiple tasks in parallel using asyncio + thread pool. Up to 50 concurrent workers (configurable). Tasks are returned in the same order they were submitted. Args: tasks: List of prompt strings. model: Model key or full name (None = auto-select per task). system_prompt: Shared system message applied to every task. max_tokens: Max output tokens per task. temperature: Sampling temperature. max_workers: Override concurrent workers (default: self.max_workers). Returns: KimiSwarmResult with ordered results and aggregate stats. r/c >^^# [R"T5m[R"5mS[S[4UUUUUUU 4Sjjn[R "T Vs/sH o"U5PM sn6IShvN $s snfN 7f)N task_promptr/c ># TIShvN TRSU4UUUUU4Sjj5IShvN sSSS5IShvN $N:NN !,IShvN (df  g=f7f)Nc*>TRUTTTTS9$)N)rr'rrrr)prr'r3rrs r4YKimiExecutor.execute_tasks_parallel.._run_all.._run_one..s"dll#$"'*7'1(3 /;/r7)run_in_executor)rlooprr'r3semrrs r4_run_oneGKimiExecutor.execute_tasks_parallel.._run_all.._run_onesG3!%!5!5!, " 33 333sRA%AA%!A AA  A%A A%A  A% A"A  A"A%)asyncio Semaphoreget_event_loopr@r#gather) rtrreffective_workersrr'r3rrrs @@r4_run_all5KimiExecutor.execute_tasks_parallel.._run_allsj##$56C))+D C O  !u)Eu!(1+u)EFF F)EFsABA<0B7B8 BrNr)rac38# UHoRv M g7fr1)r(.0rQs r4 6KimiExecutor.execute_tasks_parallel..s?,Q==,c38# UHoRv M g7fr1)r)rs r4rrs?,Q,rc3J# UHoR(dMSv M g7f)rN)r%rs r4rrsA|!yyAA|s# #)rHrIrKrLrMrN)rErirarjrrr r#rr is_runningconcurrent.futuresfuturesThreadPoolExecutorsubmitrunrrun_until_completersum)r3rr'rrrrarrr concurrentpoolfuture results_listrrIrKrMrNrs`````` @r4execute_tasks_parallel#KimiExecutor.execute_tasks_parallelrsn4"$ $  +4++ " J  YY[  G_ 5 G G( 3))+D  )''::q:IT![[hjAF:@--/LJI $66xzB ))+ *?,?? ?,?? A|AA L)M9  %!#''   JI  3";;xz2L 3s77AF>6E>4F=F> F F F%F76F7c *UR"SSU0UD6$)zh Synchronous single-task execution. Matches the genesis_execution_layer.execute_task_sync() signature. rr8r)r3rkwargss r4execute_task_syncKimiExecutor.execute_task_syncs ||242622r7rprompt_previewc [R"5R5URURUR UR [URS5[URS5URURUS. n[URSSS9nUR[R "U5S-5 SSS5 g!,(df  g=f!["a gf=f) z-Append a JSONL log entry for budget tracking.) timestampr'r-r.rIcost_usdexecution_time_sr%r+rautf-8encoding N)rnow isoformatr'r-r.r(roundr)r*r%r+openrkwritejsondumpsr)r3rrentryfhs r4rKimiExecutor._log_usages"113\\#11!'!9!9"..f22A6 %f&;&;Q ?~~#11,   d))3ARE*T12BAA   s0C,))CC, C)%C,)C,, C98C9c UR5UR[URURUR [ URS5UR(a#URSSSURSS3S.$SS.$)z@Return current executor status (mirrors GeminiExecutor pattern).Nrz...zNOT SET) configuredr`rrarnrItotal_cost_usdapi_key_preview) r}r`rrarnrIrrKr_r2s r4 get_statusKimiExecutor.get_statuss,,.!//)++++ --#DOOQ7<<<<#$C RS(9':;    r7cSnSnURR5(aW[URSSS9nUH3n[R"U5nXR SS5- nUS- nM5 SSS5 US:aX- OSn[US 5U[US 5[[R55S .$![R [4a Mf=f!,(df  Nq=f) zAGet cost tracking (parallel to GeminiExecutor.get_budget_status).rJrrQrrrrNrr)total_spent_usdrnavg_cost_per_callmodels) rkexistsrr loadsrgJSONDecodeErrorKeyErrorrrZrfvalues)r3spentcallsr liner avgs r4get_budget_statusKimiExecutor.get_budget_statuss    % % ' 'd))3ARD $ 4 0:s!;;  B %qyemc$UA !&sA?1134   !00(; BAs/C/B=/C=CCCC C,)ror_r`rarnrKrIrk)NN ffffff?)NNr%r&N)r9r:r;r<r=DEFAULT_CONCURRENT_WORKERSr r@rArp staticmethodrer>r}rrBrrr#rr rErrrrrrr#rCr8r7r4r]r]s "&'5 # ,8C="t" " c # # RW   S S  * $'+ | | }|  } |  |  |  | F $'+ %)V CyV }V  } V  V  V c]V  V t3c33#$, DcN " 4S> r7r]_default_executorr/c0[c [5q[$r1)r)r]r8r7r4_get_default_executorr+s (N r7rc 8[5R"U40UD6$)z Drop-in replacement for genesis_execution_layer.execute_task_sync(). Routes through the Moonshot API with auto model selection. )r+r)rrs r4rr"s ! " 4 4T DV DDr7rc 8[5R"U40UD6$)uC Parallel swarm execution — up to 50 concurrent workers. Example: from core.kimi_executor import execute_tasks_parallel results = execute_tasks_parallel([ "Summarise the Q1 revenue pipeline", "Draft outreach email for TradiesVoice", ]) for r in results.results: print(r.response) )r+r)rrs r4rr+s ! " 9 9% J6 JJr7cR[S5 [S5 [S5 [5nUR5(d"[S5 [S5 [S5 gUR5n[SUS35 [S US 35 [S US 35 [5 [S 5 UR SSSS9nUR (a[S5 [SUR R535 [SUR35 [SURS35 [SURSS35 [SUR35 O[SUR35 g[5 [S5 UR/SQSSSS9nUR(a[S URS![!UR"5S"35 [%UR"S#5H/upE[S$US%UR R5<35 M1 [S&UR&35 [S'UR(S35 [S(UR*SS35 Ot[S)UR,S*35 UR"H.nUR (aM[S+UR35 M0 URS,:a [S-5 Og[5 [S5 [S.5 [S5 g/)0zi Execute a live API call against Moonshot and print results. Returns True on SUCCESS, False on failure. z<============================================================uKIMI EXECUTOR — LIVE TESTz [FAIL] MOONSHOT_API_KEY not set.z% Add to E:\genesis-system\.env:z MOONSHOT_API_KEY=sk-...Fz API Key : rz Model : r`z Workers : raz1--- Test 1: Single execution (moonshot-v1-8k) ---z*What is 2 + 2? Reply with just the number.r)rr'rz SUCCESSz Response : z Tokens : z Cost : $z.8fz Latency : z.2fsz Model : z FAILED: z8--- Test 2: Parallel swarm (3 tasks, moonshot-v1-8k) ---)zReply with just the word: ALPHAzReply with just the word: BETAzReply with just the word: GAMMAr)rr'rrau SUCCESS — /z tasks passedrz Task z: z Total tokens : z Total cost : $z Wall time : u PARTIAL FAILURE — z tasks failedz Error: ru8 (Partial success — rate limit transient, acceptable)zKIMI EXECUTOR TEST: SUCCESST)printr]r}rrr%r&rxr(r)r*r'r,rrXrMrrH enumeraterIrKrLrN)executorstatusr swarm_resultirQs r4_run_live_testr8?s  (O '( (O~H  ! ! # # 01 78 ./  "F Jv/01 23 Jvo./ 01 Jvm,- ./ G =>   ;F ~~  foo335678 f00123 v33C89: f33C8:; fll^,- 6<<.)* G DE22 3 L |99:!C @T@T "<#:#:3"?@A !,">">s!C1EF &|'A'A&B-PQ%%A999 !''+,&  % % * L M G (O '( (O r7__main__r)1r=rr rvr dataclassesrrrpathlibrtypingrrr r dotenvr __file__rl _env_pathrrrfrr@rBr?rhrjr'rrrrrr#rEr]r)r+rrr>r8r9sysokexitr8r7r4rCs D (,, "X%%,,v5I 1   ! #'$7"&$7"&$71$sDe,,- "  5+  . '' '8~ ~ L -18L)0|ECEoE K$s) K/ K(PPf z  BHH"Q!A  s-D!!D*)D*