ibdZddlZddlZddlZddlZddlZddlmZmZddlm Z ddl m Z m Z m Z mZddlmZmZe dZej&j)deeddlmZej0d ZeGd d ZeGd d ZGddZedk(reZyy)ag Antigravity Workflow Engine =========================== The core execution engine for autonomous genesis system development. Synthesizes high-level goals into executable steps. Architecture: - Plan: Synthesized by Gemini (Pro/Flash) - Execute: Step-by-step implementation with verification - Memory: Recursive integration of results into the knowledge base N)datetimetimezone)Path)AnyDictListOptional) dataclassasdictz/mnt/e/genesis-system)GeminiExecutorzcore.antigravity_workflowcbeZdZUeed<eed<eed<dZeed<dZeeed<dZeeed<y) WorkflowStepid descriptionactionpendingstatusNresulterror) __name__ __module__ __qualname__str__annotations__rrr r2/mnt/e/genesis-system/core/antigravity_workflow.pyrr s8 G KFC FHSM E8C=rrcJeZdZUeed<eed<eeed<eed<dZeed<y) WorkflowPlanplan_idgoalsteps created_atplannedrN)rrrrrrrrrrrrr)s& L I  OFCrrc<eZdZdZdZd dededefdZdedefd Z y) AntigravityWorkflowz< Orchestrates goal-to-execution cycles for Genesis. ctd|_tdz dz dz |_tdz dz dz |_|jj dd|jj ddy)NT)use_rate_maximizerdatazantigravity-syncplans executions)parentsexist_ok)r executor GENESIS_ROOT plans_direxec_dirmkdir)selfs r__init__zAntigravityWorkflow.__init__6sj&$? %.1CCgM$v-0BB\Q  TD9 D48rNr!contextreturncd|dtj|xsid}|jj|d}|jst d|j  |jj}d|vr5|jddjd d j}n8d |vr4|jd djd d j}tj|}|Dcgc] }tdi|}}d ttj} t| ||tj t"j$j' } | Scc}w#t($rM} t*j d | t*j d|jt d| d} ~ wwxYw)zH Synthesize a goal into a multi-step plan using Gemini. z# GOAL: z # CONTEXT: az Act as the Genesis System Architect. Break this goal down into exact, executable technical steps. Return ONLY a JSON list of steps. Each step MUST have: - "id": unique string ID - "description": clear explanation of what to do - "action": the specific technical implementation instruction Response Format: [ {"id": "step_1", "description": "...", "action": "..."}, ... ] architecture task_typezFailed to create plan: z```jsonz```rplan_)r r!r"r#zError parsing plan: zRaw response: zPlan synthesis failed: Nr)jsondumpsr.execute_optimizedsuccess RuntimeErrorrresponsestripsplitloadsrinttimerrnowrutc isoformat Exceptionlogger) r3r!r5promptrB cleaned_resp steps_datasr"r planes r create_planzAntigravityWorkflow.create_plan=sdV$ JJw}" % & '==226^2T!88HIJ J >#,,224LL(+11) LL/s3 4 LL>(*;*;)<= >!8<= = >s-#B$FE;A!F;F G AGG plan_datac|jd}|jdg}g}td||D] }tdi|}td|jd|jd|jdd|jd |j d }|j j|d }|jrd |_ |j|_ nd|_ |j|_ |jt||jdk(std|jd|jn|td|Drd |dSd|dS)z- Execute a synthesized plan. r r"zorkflow] Executing plan: z > Step z: z ## GOAL: r!z ## STEP DESCRIPTION: z ## ACTION: z Implement this step. If it involves code, provide the code. Verify the implementation. If complete, end with TASK_COMPLETE. code_generationr9 completedfailedz X Step z FAILED: c3,K|] }|ddk(yw)rrWNr).0rs r z3AntigravityWorkflow.execute_plan..s(U8 )C(Uspartially_failed)r rresultsr)getprintrrrrr.r?r@rrBrrappendr all) r3rTr r"r^ step_datastep exec_promptresps r execute_planz AntigravityWorkflow.execute_planmsf-- * gr* +G956 I,),D IdggYb)9)9(:; <( f(='>?&&'( KK=K==22;J[2\D||) "mm & !ZZ NN6$< ({{h& $'')DJJ<@A5 :%((UW(U%Uk  [m  r)N) rrr__doc__r4rdictrrSrgrrrr&r&1s:9.>.>d.>l.>`* d* t* rr&__main__)rhr=loggingossysrGrrpathlibrtypingrrrr dataclassesr r r/pathinsertrcore.gemini_executorr getLoggerrLrrr&rworkflowrrrrvs   ',,)+, 3|$%/   6 7       f f P z"$Hr