iG &%SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r J r SSK J r SSK J r SSKJrJrJrJr \R&"S\R&"SS 55rS rS r\\\S .rS rSr\ "SS55r\ "SS55r"SS5r0r\\\4\S'\R@"5r!S$S\S\4Sjjr"S%S\S\S\\S\#S\4 Sjjr$S\4S\\\\4S\S\#S\\4S jjr%S$S\S\\\44S!jjr&S"r'\(S#:Xa\'"5 gg)&a KIMI K2.5 SWARM INTEGRATION ============================ Moonshot AI's Kimi K2.5 as a Genesis execution backend. Native PARL capabilities: - 100 sub-agents per API call - 1500 tool calls - 8K / 32K / 128K context windows - OpenAI-compatible API (drop-in replacement) OpenRouter API base URL: https://openrouter.ai/api/v1 Model: moonshotai/kimi-k2.5 Usage: from core.kimi_swarm import KimiSwarm, execute_kimi_task, execute_kimi_swarm # Single task result = execute_kimi_task("Summarise this 100K doc", model="max") # Parallel swarm results = execute_kimi_swarm([ {"prompt": "Analyse revenue pipeline"}, {"prompt": "Draft marketing copy for TradiesVoice"}, {"prompt": "Research competitor pricing"}, ]) Author: Genesis System Version: 1.0.0 N) dataclassfield)datetime)Path)DictListOptionalAnyOPENROUTER_API_KEYMOONSHOT_API_KEYzhttps://openrouter.ai/api/v1zmoonshotai/kimi-k2.5faststandardmax 2c\rSrSr%Sr\\S'\\S'Sr\\S'Sr \\S'Sr \\S'S r \ \S 'S r \ \S 'S r\\S 'Sr\\\S'\"\S9r\\\4\S'S\4SjrSrg) KimiResponseIz)Structured response from a Kimi API call.textmodelr prompt_tokenscompletion_tokens total_tokensexecution_time cost_estimateTsuccessNerrordefault_factory raw_responsereturncUR$N)rselfs $E:\genesis-system\core\kimi_swarm.py__str__KimiResponse.__str__Ws yy)__name__ __module__ __qualname____firstlineno____doc__str__annotations__rintrrrfloatrrboolr r rdictr#rr r*__static_attributes__r-r,r)rrIs}3 I JM3sL#NEM5GTE8C=#(#>L$sCx.>r,rc\rSrSr%Sr\"\S9r\\ \ S'Sr \ \ S'Sr \\ S'Sr\\ S 'Sr\ \ S 'Sr\ \ S '\S \\4S j5r\S \4Sj5rSrg)KimiSwarmResult[z'Result from a parallel swarm execution.r! responsesrrr total_costelapsed_seconds success_count failure_countr$c~URVs/sH!oR(dMURPM# sn$s snf)z7Return just the text strings from successful responses.)r=rr)r(rs r)textsKimiSwarmResult.textses*!%<1))<<r6r?r@rApropertyr3rDr7rGr9r-r,r)r;r;[s1$)$$?ItL!?L#J OU M3M3 =tCy=='T''r,r;c ^\rSrSrSrSr\R"5rSS\ 4U4Sjjjr SS\ 4Sjjr Sr S\ S\ S \ S \4S jrSS \ S \4SjjrS \4SjrSS\ S\\ S\ S\S\\ S \4 Sjjr\4S\\\ \4S\ S \4SjjrS S\ S\\ S\ S\S \4 Sjjr\4S\\\ \4S\ S \4SjjrS \\ \44SjrSrU=r $)! KimiSwarmsz Kimi K2.5 swarm executor with native PARL capabilities. Singleton-safe. Thread-safe for parallel swarm use. Modelled after Genesis's Qwen/Gemini integration patterns. Nrc">[TU]U5$r&)super__new__)clsr __class__s r)rPKimiSwarm.__new__~sws##r,c\Xl[RU[S5Ul[Ul[ Ul[[5RRS- S- Ul URRRSSS9 SUl SUlSUlSUlg)Nrdatazkimi_usage.jsonlT)parentsexist_okrr) model_key KIMI_MODELSgetrr api_keyOPENROUTER_BASE_URLbase_urlr__file__parentlog_pathmkdir total_callsrr>_client)r(rs r)__init__KimiSwarm.__init__s __UK ,CD ) + X--44v=@RR  ""4$"? r,cURc3SSKJn U"URURS9UlUR$UR$![ a [ S5ef=f)z>Lazy-load OpenAI client (OpenAI-compatible Moonshot endpoint).r)OpenAI)r[r]z5openai package not installed. Run: pip install openai)rcopenairgr[r] ImportError RuntimeError)r(rgs r) _get_clientKimiSwarm._get_clientsd <<  )% LL!]]  ||t||  "K s &A A#rrr$cb[RUSSS.5nUS- US-US- US--$)z$Estimate USD cost from token counts.g333333?)inputoutputi@Brnro) KIMI_PRICINGrZ)r(rrrpricings r)_estimate_costKimiSwarm._estimate_costsH""5DD*IJ Y &''*: :  *gh.? ? @ r,eventrUcJ[R"5R5UURU=(d 0S.n[ UR SSS9nUR [R"U5S-5 SSS5 g!,(df  g=f![a gf=f)zAppend a JSONL log entry.) timestamprtrrUazutf-8)encoding N) rnow isoformatropenr`writejsondumps Exception)r(rtrUentryfs r)_logKimiSwarm._logs|"113ZZJB    dmmS7;q 5)D01<;;   s/B)B;B BBB B"!B"cn[UR=(a URR55$)zCheck if API key is set.)r7r[stripr's r)_is_configuredKimiSwarm._is_configureds#DLL9T\\%7%7%9::r,promptsystem max_tokens temperaturemodel_overridec UR5(d[SURSSS9$U=(d URn[R"5n/nU(aUR SUS.5 UR SUS.5 UR 5n U R RRUUUUS9n [R"5U- n U Rn U (a U ROS n U (a U ROS nU (a U ROS nURXmU5nU=RS - slU=RU- sl U=RU- slU R S R"R$=(d SnUR'S US S UU[)U S5S.5 [UUU UUU USU R*U RS.S9 $![,a]n[R"5U- n [/U5nUR'SUS S U[)U S5S.5 [SUU SUS9sS nA$S nAff=f)a& Execute a single Kimi task. Args: prompt: The user prompt system: Optional system message max_tokens: Max tokens to generate temperature: Sampling temperature (0-1) model_override: Override the default model for this call Returns: KimiResponse with text and metadata r Fz`OPENROUTER_API_KEY not set. Get key from https://openrouter.ai and add to E:\genesis-system\.envrrrr r)rolecontentuser)rmessagesrrrexecute_successNd)prompt_previewtokenscost_usd elapsed_sT)idr) rrrrrrrrr# execute_error)rr r)rrrrr )rrrtimeappendrkchat completionscreateusagerrrrrrbr>choicesmessagerrroundrrr3)r(rrrrrr start_timerclientresponseelapsedrrrrcostre error_msgs r)executeKimiSwarm.executes8*""$$jjz  ,$**YY[   OOX&A BF;<; %%'F{{..55!%' 6HiikJ.GNNE38E//aM;@ 7 7a 165--AL&&u=NOD    !     -  OOt #O##A&..66<"D II'"(#,& "7A. *  +"3)&"$,KK(..I   iikJ.GAI IIo"(#,""7A.(   &   s E!G** I4AI I Itasks max_workersc ^U(d [5$[R"5n[U[[ U55nTR S[ U5US.5 S[ S[4U4Sjjn/n[RRUS9n[U5VV s0sHupURXY5U_M n nn S/[ U5-n [RRU 5Hn Xn U R5X'M U nSSS5 [R"5U- n[%S U55n[ U5U- n[%S U55n[%S U55nTR SUUUU['US5S.5 [UUUUUUS9$s sn nf![a,n[STR S [#U5S 9X'SnAMSnAff=f!,(df  N=f)ua Execute multiple tasks in parallel using ThreadPoolExecutor. This leverages Kimi's native PARL architecture — up to 100 concurrent sub-agents, each running an independent chain of up to 1500 tool calls. Args: tasks: List of task dicts with keys: - prompt (required) - system (optional) - max_tokens (optional, default 4096) - temperature (optional, default 0.7) - model_override (optional) max_workers: Parallel threads (max 50 via this wrapper; Kimi supports 100 native) Returns: KimiSwarmResult with all responses and aggregate stats swarm_start) task_countworkerstaskr$c >TRURSS5URSS5URSS5URSS5URSS5S 9$) Nrr rrrffffff?r)rrrrr)rrZ)rr(s r)run_task)KimiSwarm.swarm_execute..run_taskAs`<<xx"-xx$/88L$7 HH]C8#xx(8$?   r,)rNr Frc3\# UH"o(dM UR(dMSv M$ g7f)rN)r.0rCs r) *KimiSwarm.swarm_execute..ZsDy!AA!))AAys ,, ,c3J# UHo(dM URv M g7fr&)rrs r)rr\sB9a>1>>9 ##c3J# UHo(dM URv M g7fr&)rrs r)rr]sA)Qq)rswarm_completer)rfailedrtotal_cost_usdr)r=rr>r?r@rA)r;rminMAX_SWARM_WORKERSlenrrr concurrentfuturesThreadPoolExecutor enumeratesubmit as_completedresultrrr3sumr)r(rrreffective_workersrr=executorir future_maporderedfutureidxrrr@rArr>s` r) swarm_executeKimiSwarm.swarm_executes."$ $YY[  ->E K -e*("   4 L     2 2?P 2 QU]LUV[L\]L\(//(91TRTTTT5$r&)r)rrr(rrsr))KimiSwarm.execute_async..{sDLL[Ir,asyncioget_event_looprun_in_executor)r(rrrrloops````` r) execute_asyncKimiSwarm.execute_asyncps<%%'))  I I    s3A?Ac~^^^# [R"5nURSUUU4Sj5IShvN $N7f)z Async wrapper for swarm_execute.Nc(>TRTT5$r&)r)rr(rsr)r/KimiSwarm.swarm_execute_async..sD&&uk:r,r)r(rrrs``` r)swarm_execute_asyncKimiSwarm.swarm_execute_async~s9 %%'))  :    s 1=;=c 2UR5URURURURUR [ URS5[UR5UR(aURSSS3S. $SS. $)zReturn current client status.Nz...zNOT SET) configuredrrXr]rbrr api_key_setapi_key_preview) rrrXr]rbrrr>r7r[r's r) get_statusKimiSwarm.get_statuss--/ZZ ++ --#DOOQ7 -;?<<$,,r"2!337  NW  r,) rcr[r]r`rrXrbr>rrr&)NrrN)Nrr)!r.r/r0r1r2 _instance threadingLock_lockr3rPrdrkr5r6rrrrr7rr rrDEFAULT_SWARM_WORKERSrr r;rrrrr9 __classcell__)rRs@r)rLrLssI NN E$C$$c$  C  PS X]  # T ;;!% (, `` ` `  ` ! ` `J1O DcN#O O   O h!%             "1  DcN#         DcN   r,rL _instancesrrr$c[ U[;a[US9[U'[UsSSS5 $!,(df  g=f)z;Get or create a singleton KimiSwarm for a given model tier.rN)_instances_lockrrLrs r) _get_instancers.   " ) 6Ju %  s #4 ArrrcP[U5nURXUS9nUR$)z Quick single-task Kimi executor. Returns the response text directly (empty string on failure). Check KimiSwarm.execute() for structured response with metadata. )rrr)rrr)rrrrswarmrs r)execute_kimi_taskrs* % E}}Fj}QH ==r,rrcN[U5nURXS9nUR$)a Quick parallel swarm executor. Returns list of response texts in submission order. Args: tasks: List of {"prompt": ..., "system": ..., "max_tokens": ...} model: "fast" | "standard" | "max" max_workers: Parallel threads Example: results = execute_kimi_swarm([ {"prompt": "Analyse Q1 revenue"}, {"prompt": "Draft tradie outreach email"}, {"prompt": "Research Moonshot pricing"}, ]) )rr)rrrD)rrrrrs r)execute_kimi_swarmrs+, % E  u FF <<r,c4[U5R5$)z*Return status dict for a given model tier.)rrrs r) kimi_statusrs   * * ,,r,cSSKnURSS9nURS/SQSSS 9 URS [S S S 9 URSSSS9 UR 5nUR (a1SSKn[UR[UR5SS95 g[SURS35 [URS9nUR5nUS(dY[S5 [S5 [S5 [S5 [S5 [S5 [S5 [S5 gURUR5nUR(a[S 5 [S!UR35 [S"UR 35 [S#UR"35 [S$UR$S%35 [S&UR&S'S(35 g[S)UR(35 g)*z4Run a quick connectivity test from the command line.rNu'Kimi K2.5 Swarm — Genesis Integration) descriptionz--modelrrzModel tier to test)rdefaulthelpz--promptz*What is 2 + 2? Reply with just the number.z Test prompt)typerr z--status store_truezShow status only)actionr )indentzTesting Kimi K2.5 (z) ...rrz" [ERROR] MOONSHOT_API_KEY not set.zTo get your key:z' 1. Go to https://platform.moonshot.cnz 2. Create account / log inz! 3. Navigate to API Keys sectionz 4. Create a new keyz# 5. Add to E:\genesis-system\.env:z MOONSHOT_API_KEY=sk-...z [SUCCESS]z Model: z Response: z Tokens: z Cost: $z.6fz Latency: z.2fsz [FAILED] )argparseArgumentParser add_argumentr3 parse_argsstatusr~printrrrrLrrrrrrrrr )rparserargs_jsonrrrs r) _cli_testrs  $ $1Z $ [F  +FPV13  6b*,  <>PQ    D {{ ekk+djj1!k<=  |5 12 DJJ 'E    F ,  34  ! 78 ,- 12 %& 56 ,-}}T[[)H  8>>*+, 8==/*+ 800123 H223789 82237q9: HNN+,-r,__main__r)rNr))r2osr~rrconcurrent.futuresrr dataclassesrrrpathlibrtypingrrr r getenvr r\ KIMI_MODELrYrrrr;rLrr3r4rrrr5rrrrr.r-r,r)r"s> (,,YYII "% 5 #    " '' '.c c V $& Di %.."!!i!     SM   &, S#X   #Y 6-s-DcN-*.Z z Kr,