'iYaSrSSKrSSKrSSKrSSKJrJr SSKJr SSKJ r J r J r J r SSK Jr SSKJr \"\5R$R$S- r\"\5 SSKJr S rSS KJrJr S r\"S S 55r "SS5r!\"SS55r""SS5r#Sr$\%S:Xa\$"5 gg!\a N`f=f!\a S rSSKrSSKrNmf=f!\a S rSrNrf=f)aI GENESIS GEMINI EXECUTOR ======================= Direct Gemini API execution for Hyperdrive mode. Uses $300 Google AI Studio credits. No Antigravity proxy needed - direct API calls. Models (January 2026 - Updated): - gemini-2.0-flash: Primary workhorse (2K RPM, 4M TPM, Unlimited RPD) - gemini-2.5-flash: Newer model (1K RPM, 1M TPM, 10K RPD) - gemini-2.5-pro: Complex reasoning (150 RPM, 2M TPM, 10K RPD) - gemini-2.0-flash-lite: High throughput simple tasks (4K RPM) Integrated with GeminiRateMaximizer for intelligent rate limit management. Usage: executor = GeminiExecutor() result = executor.execute("Implement feature X") print(result.response) # With rate limit awareness executor = GeminiExecutor(use_rate_maximizer=True) result = executor.execute_optimized("Analyze this code", task_type="code_review") N)datetime timedelta)Path)DictOptionalAnyList) dataclass) load_dotenvz.envTF)GeminiRateMaximizerTaskTypect\rSrSr%Sr\\S'\\S'\\S'\\S'\ \S'\ \S'\\S 'S r \ \\S 'S r g ) GeminiResponse=zResponse from Gemini execution.successresponsemodel tokens_used cost_estimateexecution_time task_completeNerror) __name__ __module__ __qualname____firstlineno____doc__bool__annotations__strintfloatrr__static_attributes__r)E:\genesis-system\core\gemini_executor.pyrr=s:) MM JE8C=r%rc\rSrSrSr/SQrSSSSSS .rS S S S S SS S.rSSSSSSSSSS. rS/S\ S\ S\ 4Sjjr S\ \ 4Sjr S0S\ S\ S\ S\S\S\ S\4SjjrS1S\ S\ S\ S\S\S \S\ S\4S!jjrS\ \4S"jrS2S#\S\ S\ 4S$jjrS3S\ S\ S\ S\S\S\ S\ 4S%jjrS\ S\ S\ S\S\S\ 4 S&jrS'\S(\ 4S)jrS4S*\S+\ S\4S,jjrS\4S-jrS.rg)5GeminiExecutorJz Direct Gemini API executor for Genesis Hyperdrive. Uses $300 in Google AI Studio credits. No proxy needed - direct API calls. )GEMINI_API_KEYGOOGLE_API_KEYzJE:/genesis-system/Credentials/GoogleAIStudio-Gemini-AgileAdapt-API-KEY.txtgemini-3-flash-previewgemini-2.5-flashgemini-3-pro-previewgemini-2.0-flash-litegemini-2.0-flash-exp)flashflash2proliteexpg?g333333?g@g333333?g333333?)zgemini-2.0-flashr,r.r-zgemini-2.5-pror/r0) researchcode_generation code_review architecturesimple_extractionclassification summarizationagentic_vision deep_visionNapi_key default_modeluse_rate_maximizercU=(d UR5UlURRX"5Ul[ S5UlSUlSUlU(a[(a[5Ul[(a1UR(a[R"URS9 ggg![an[SU35 SnANZSnAff=f)Nz)E:/genesis-system/data/gemini_usage.jsonlz.Warning: Could not initialize rate maximizer: r?) _load_api_keyr?MODELSgetr@rusage_log_path total_spentrate_maximizerRATE_MAXIMIZER_AVAILABLEr ExceptionprintGENAI_AVAILABLEgenai configure)selfr?r@rAes r&__init__GeminiExecutor.__init__zs6$"4"4"6 ![[__]J"#NO# ":": L&9&;# ?t|| OODLL 1 ,? LFqcJKK Ls0B<< CCCreturncpURSSH-n[RRU5nU(dM+Us $ [ URS5nUR 5(aIUR 5R5nSU;a#URSS5SR5$U$g)z&Load API key from environment or file.N=) API_KEY_SOURCESosenvironrGrexists read_textstripsplit)rQenv_varkeykey_filecontents r&rEGeminiExecutor._load_api_keys++BQ/G**..)Cs 0 ,,Q/0 ??  ((*002Gg~}}S!,Q/5577Nr%promptr system_prompt max_tokens temperaturecached_content_namec U(aURRX"5O URn[R"5nUR(d[ SSUSSSSSS9$[ (aURXX4XV5n OURXX4U5n [R"5U- n [U R55S-n U S- URRUS5-n S U ;n [ S U U[U 5U U U S 9nURXS S 5 U=RU - slUR(aS[UR55S-nU(aSnURR!U[U5[U 5S S9 U$!["a9n[ SSUSS[R"5U- S[%U5S9sS nA$S nAff=f)ag Execute a prompt with Gemini. Args: prompt: The task/prompt to execute model: Model to use (flash, pro, exp, or full model name) system_prompt: Optional system instruction max_tokens: Max output tokens temperature: Sampling temperature cached_content_name: Optional Titan Memory name to use Returns: GeminiResponse with results FrzNo API key configured)rrrrrrrr?i@B? TASK_COMPLETET)rrrrrrrNd) input_tokens output_tokensr)rFrGr@timer?rrN_execute_with_sdk_execute_with_restlenr`COSTSr" _log_usagerIrJ record_usagerLr!)rQrfrrgrhrirj model_name start_timerrtokens_estimatecostrresultrqrRs r&executeGeminiExecutor.executes.7>*d3SSD,x7M#! 0"-+F OOF4CL 1    $ """6<<>2S8 &#$L##00!$\!2"%o"6 1M ! #yy{Z7#!f   s&D3F G$.GGG task_typepriorityc L[[UR55S-5U-nUR(a[(aSn [ (a [ U5n URRUU =(d [ RUS9n U Rn U RS:a [R"U R5 O%URRX R5n UR!UU UUUUS9$![ a [ Rn Nf=f)a; Execute with intelligent model selection and rate limit awareness. Uses the GeminiRateMaximizer to select the best available model based on current utilization and task type. Args: prompt: The task/prompt to execute task_type: Type of task for routing (research, code_generation, etc.) system_prompt: Optional system instruction max_tokens: Max output tokens temperature: Sampling temperature priority: Request priority (1-10, lower = higher) cached_content_name: Optional Titan Memory name to use Returns: GeminiResponse with results rmN)token_estimaterrr)rfrrgrhrirj)r"rvr`rJrKr ValueErrorGENERALschedule_requestr delay_secondsrssleep TASK_ROUTINGrGr@r) rQrfrrgrhrirrjrtask_type_enum scheduledrs r&execute_optimized GeminiExecutor.execute_optimizeds:S0367*D   #;#;!Nx6%-i%8N ++<<-(z5 Manages the 'Titan' memory layer (Context Caching). r?cdXl[(a[R"URS9 gg)NrD)r?rNrOrP)rQr?s r&rSTitanMemoryManager.__init__Cs! ? OODLL 1 r%Nfilesrr ttl_minutesrUc p[(d [S5 gU=(d! S[[R"553n/n[S[ U5S35 UHnUR 5(dMSnUR S:XaSnO8UR S :XaS nO%UR S :XaS nOUR S :XaSn[R"XgURS9nURU5 M [S5 UHqn U RRS:XdM[R"S5 [R"U R5n U RRS:XaMRMs [SUS35 [RRR!UUSU[#US9S9n [%U RU R&U R([+U R,5U R.R0US-S9$![2an [SU 35 Sn A gSn A ff=f)z7 Create a new Titan Memory block from a list of files. z4Error: Titan Memory requires google-generativeai SDKNgenesis_memory_zTitan Memory: Uploading z files...z text/plainz.pyz text/x-pythonz.mdz text/markdownz.jsonrz.htmlz text/html)path mime_typerz,Titan Memory: Waiting for file processing... PROCESSINGrYzTitan Memory: creating cache 'z'...ztYou are the Genesis System. You have full recursive knowledge of your own source code provided in this memory block.)minutes)rrrrttl<)rrrrrrzTitan Memory Error: )rNrMr"rsrvr]suffixrO upload_filerappendstaterget_filerrcreaterrrrr!rusage_metadatatotal_token_countrL) rQrrrruploaded_files file_pathrpfrrrRs r& create_memory TitanMemoryManager.create_memoryHs H I0 'O_S=MP)%%0k)&&IYbYgYgh%%b)# @ A#gglll2JJqMqvv.Agglll2$ 2<.E FMM//66)$Z'k2 7EZZ"//kk 1 12!00BB'",    (, - s&D H&AH8BH H5H00H5rc2[(dg[RRR U5n[ UR URUR[UR5URRS9$![a gf=f)z"Retrieve an existing memory block.Nrrrrr)rNrOrrrGrrrrr!rrrrL)rQrrs r& get_memoryTitanMemoryManager.get_memorys}t MM//33D9EZZ"//kk 1 12!00BB    sA:B BBc h[(d/$/n[RRR 5HdnUR [ URURUR[UR5URRS95 Mf U$![a U$f=f)zList all active memories.r)rNrOrrlistr rrrrr!rrrrL)rQmemoriesrs r& list_memories TitanMemoryManager.list_memoriessr  4499; !&!3!3++ #E$5$5 6 % 4 4 F F !<   sBB## B10B1rD)Nzgemini-2.0-flash-001r)rrrrrr!rSr rr"rrrrrr$rr%r&rr>s22!+ >Dz>> >  > +  >@ s x '< tK0r%rcf[5n[S5 UR(d [S5 g[SURSSSURSS35 [SUR35 [S 5 UR S S S 9n[S UR 35 [SUR SS35 [SUR35 [SURS35 [SURSS35 [(a+[S5 [UR5n[S5 UR(a[SUR35 [S5 UR5nUR5HupE[USU35 M g)zQuick test of Gemini execution.z=== GEMINI EXECUTOR TEST ===\nzERROR: No API key found!Nz API Key: z...zDefault Model: z\n--- Testing Simple Prompt ---z*What is 2 + 2? Reply with just the number.r1)rz Success: z Response: rpzTokens: zCost: $z.4fzTime: z.2fsz)\n--- Testing Titan Memory Capability ---zTitan Manager initialized.zError: z\n--- Budget Status ---r)r(rMr?r@rrrrrrrNrrritems)executorr~titanstatusrbvalues r& test_geminir'sH +,    () Ih&&s+,C0@0@0E/F GH OH223 45 ,-   4F  Ifnn% &' Jvt,- ./ HV''( )* GF((- ./ F6((-Q /0 :;"8#3#34 *+||  ~&' $%  ' ' )Flln  Rw %r%__main__)&rr[rrsrrpathlibrtypingrrrr dataclassesr dotenvr __file__r _env_path ImportErrorgoogle.generativeai generativeairOrNurllib.requestr urllib.errorcore.gemini_rate_maximizerr r rKrr(rrr'rrr%r&r5s4 (,,! "X%%,,v5I  'OH#        b b J     hhV*!Z zM]  O$Hs5-B5C' C5B>=B>CC C$#C$