&ii >UdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z ddl m Z mZmZddlmZddlmZmZmZmZmZeej3j4j4Zedz dz Zej:j=deeej:j=deeeed Z d Z!d Z"d Z#dZ$dZ%dZ&gdZ'dgZ(ddiddiddiddidZ)eeeee*ffe+d<dZ,dZ-dZ.edz d z Z/edz d!z Z0edz d"z Z1ed#z d$z d%z Z2e/d&z Z3e/e0e1e2j4fD]Z4e4jkd'd'(ejlejnd)ejpee/d*z d+,ejrejtg-ejvd.Zd3e?fd4Z@d5eeefd3e?fd6ZAd5eeefd3e?fd7ZBd5eeefd3e?fd8ZCeAeBeCd9ZDd:ZEdTd;ZFdd?ZIGd@dAZJGdBdCZKGdDdEZLGdFdGZMGdHdIZNdTdJZOdUdKePd3e*fdLZQdMeed3eefdNZRd3eefdOZSdTdPZTd3ee>fdQZUdTdRZVeWdSk(reVyy)Va Alpha Evolve Daemon -- Autonomous Nightly Evolution System =========================================================== Runs at 03:00 AEST daily. Applies Darwinian selection pressure to Genesis revenue-generating assets (Phase 1: email templates via Instantly.ai). 6-Phase Cycle: HARVEST -> CULL -> MUTATE -> TEST -> ASCEND -> LOG Usage: python scripts/alpha_evolve_daemon.py --cycle # Run one evolution cycle python scripts/alpha_evolve_daemon.py --dry-run # Simulate without changes python scripts/alpha_evolve_daemon.py --status # Show current generation status python scripts/alpha_evolve_daemon.py --daemon # Run as daemon (03:00 AEST daily) Environment: INSTANTLY_API_KEY Instantly.ai API key (fallback hardcoded for Phase 1) GEMINI_API_KEY Gemini API key for mutation generation ALPHA_EVOLVE_PAUSE=true Skip current cycle ALPHA_EVOLVE_DRY_RUN=true Log only, no changes ALPHA_EVOLVE_MUTATIONS=5 Mutations per elite (default 5) Safety: - Minimum 3 survivors per asset type (never cull all) - Archive, never delete - Dry-run by default unless --cycle or --daemon is given - Pause flag checked at start of every cycle - NO SQLite -- PostgreSQL only (Elestio Bloodstream) - All paths on E: drive CRITICAL: This script does NOT activate or unpause the Instantly.ai campaign. It only READS analytics from the API. Version: 1.0.0 Phase: 1 (Email template evolution only) N) dataclassasdictfield)datetimetimezone timedelta)Path)AnyDictListOptionalTupledatazgenesis-memory )hoursz1.0.0皙?g333333?)email_template voice_prompt widget_configexecution_scriptrsent2 total_calls impressionsrunsMIN_DATA_THRESHOLDSz$cf21ba92-4c8c-443c-b67e-4b6530024118zDMjBjODUxNGYtNjA5MC00NjY4LWFhY2UtOWZmYTE3NDhhMmQ1OnRTYkpqRU94RHJveg==zgemini-2.5-prohivelogsprogressjules_evolve_tasksKNOWLEDGE_GRAPHaxiomszalpha_evolve_daemon.jsonlzmajor_improvements.logTparentsexist_okz3%(asctime)s [%(levelname)s] %(name)s -- %(message)szalpha_evolve.logutf-8encoding)levelformathandlers alpha_evolveceZdZUdZeed<eed<eeefed<eed<e eed<e ed<eed<eeefed <eed <e e Z eeefed <y )EvolutionAssetzA single evolvable asset.asset_id asset_typecontentversion parent_id fitness_scorestatusmetrics created_at)default_factorymetadataN)__name__ __module__ __qualname____doc__str__annotations__r r intr floatrdictr?4/mnt/e/genesis-system/scripts/alpha_evolve_daemon.pyr4r4}sa#MO #s(^ L} K #s(^O$T:Hd38n:rJr4ceZdZUdZeed<eed<eed<eed<eed<eed<eed<eed <eeed <eeed <e ed <y ) CycleReportzSummary of one evolution cycle.cycle_id started_at completed_at assets_scored assets_culledmutations_generatedmutations_tested promotionsmajor_improvementserrorsdry_runN) r@rArBrCrDrErFr r boolrIrJrKrMrMsK)MOOT " I MrJrMreturncJ|sytt|t|z dS)z8Safe division returning 0.0 if denominator is 0 or None.)roundrG) numerator denominators rK safe_divideras$  y!E+$66 ::rJr<c|jdd}|dkryt|jdd}t|jdd}t|jdd}t|jdd}t|jd d}|d z|d zz|d zzd |z dzzd |z dzz}td |dz }t||zdS)a} Composite fitness score for email templates. Range: 0.0 to 1.0 (higher = better) Weights: open_rate 20% -- necessary but not sufficient reply_rate 40% -- primary engagement signal conversion_rate 30% -- ultimate business value bounce_rate 5% -- deliverability health spam_rate 5% -- reputation protection rrrr\ open_rate reply_rateconversion_rate bounce_rate spam_rater皙?333333??g?gY@r]getrGminr^) r<rrcrdrerfrgraw confidences rK email_fitnessrps ;;vq !D bygkk+q12Iw{{<34JGKK(91=>O M156Kgkk+q12I D t   D  !   $ % ?d "  #S$,'J z!1 %%rJc|jdd}|dkryt|jdd}t|jdd}t|jdd}t|jd d }|d krd }n*|d krd|d z dz dzz}n|dkrd|d z dz dzz}nd }d |z dz|dzz|dzz|dzz}td |dz }t||zdS)zb Composite fitness score for voice agent prompts. Range: 0.0 to 1.0 (higher = better) rrrr\avg_duration_sec booking_rate sentiment_avgg?hangup_before_30s_raterjr皙?rigb@rhiXgffffff?g@z@g333333?rg?g>@r]rk) r<r avg_durationrs sentiment hangup_rateduration_scorernros rK voice_fitnessr|s, ++mQ/KQ%7; W 8;TUVVWHDg\\::KK    => H;A3?@aGHs1AA A/ A**A/3A:C.. D 7DD ctdz dz }|js tjd|dt}n|j d} |j }|j||jtjdy #t$r2}|jtjd|Yd }~y d }~wwxYw) z} Create genesis schema and all required tables if they do not yet exist. Idempotent -- safe to call every cycle. scriptszalpha_evolve_create_tables.sqlzDDL file not found at z -- using embedded DDLr,r-z0Schema ensured (genesis tables created/verified)z8Schema DDL partially failed (tables may already exist): N) GENESIS_ROOTexistsrr _EMBEDDED_DDL read_textcursorexecutecommitrrrollback)rddl_fileddlcurrs rK ensure_schemar)s i'*JJH ??  ,XJ6LMN  ' 2Tkkm C  CD T  NqcRSSTsAB C (C  Ca CREATE SCHEMA IF NOT EXISTS genesis; CREATE TABLE IF NOT EXISTS genesis.evolution_assets ( asset_id VARCHAR(255) PRIMARY KEY, asset_type VARCHAR(50) NOT NULL, content JSONB NOT NULL, version INTEGER NOT NULL DEFAULT 1, parent_id VARCHAR(255), fitness_score FLOAT NOT NULL DEFAULT 0.0, status VARCHAR(20) NOT NULL DEFAULT 'active', metrics JSONB NOT NULL DEFAULT '{}', metadata JSONB NOT NULL DEFAULT '{}', created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(), updated_at TIMESTAMPTZ, archived_at TIMESTAMPTZ, archived_reason VARCHAR(100), superseded_by VARCHAR(255) ); CREATE INDEX IF NOT EXISTS idx_evo_assets_type_status ON genesis.evolution_assets(asset_type, status); CREATE INDEX IF NOT EXISTS idx_evo_assets_fitness ON genesis.evolution_assets(fitness_score DESC); CREATE INDEX IF NOT EXISTS idx_evo_assets_parent ON genesis.evolution_assets(parent_id); CREATE TABLE IF NOT EXISTS genesis.evolution_cycles ( cycle_id VARCHAR(20) PRIMARY KEY, started_at TIMESTAMPTZ NOT NULL, completed_at TIMESTAMPTZ NOT NULL, assets_scored INTEGER NOT NULL DEFAULT 0, assets_culled INTEGER NOT NULL DEFAULT 0, mutations_generated INTEGER NOT NULL DEFAULT 0, mutations_tested INTEGER NOT NULL DEFAULT 0, promotions INTEGER NOT NULL DEFAULT 0, major_improvements JSONB DEFAULT '[]', errors JSONB DEFAULT '[]', dry_run BOOLEAN NOT NULL DEFAULT FALSE, cycle_version VARCHAR(20) NOT NULL ); CREATE TABLE IF NOT EXISTS genesis.mutation_test_results ( mutation_id VARCHAR(255) PRIMARY KEY, parent_id VARCHAR(255) NOT NULL, asset_type VARCHAR(50) NOT NULL, mutation_content JSONB NOT NULL, mutation_fitness FLOAT, parent_fitness FLOAT NOT NULL, test_verdict VARCHAR(20), test_details JSONB DEFAULT '{}', promoted BOOLEAN, promoted_asset_id VARCHAR(255), cycle_id VARCHAR(20) NOT NULL, created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(), evaluated_at TIMESTAMPTZ, status VARCHAR(20) NOT NULL DEFAULT 'pending' ); CREATE INDEX IF NOT EXISTS idx_mut_results_status ON genesis.mutation_test_results(status); CREATE INDEX IF NOT EXISTS idx_mut_results_cycle ON genesis.mutation_test_results(cycle_id); CREATE TABLE IF NOT EXISTS genesis.call_insights ( id SERIAL PRIMARY KEY, assistant_id VARCHAR(255) NOT NULL, call_id VARCHAR(255), duration_seconds FLOAT, sentiment_score FLOAT, booking_made BOOLEAN DEFAULT FALSE, transcript_summary TEXT, caller_number VARCHAR(30), created_at TIMESTAMPTZ NOT NULL DEFAULT NOW() ); CREATE INDEX IF NOT EXISTS idx_call_insights_assistant ON genesis.call_insights(assistant_id, created_at); CREATE TABLE IF NOT EXISTS genesis.widget_events ( id SERIAL PRIMARY KEY, widget_id VARCHAR(255) NOT NULL, event_type VARCHAR(30) NOT NULL, event_data JSONB DEFAULT '{}', created_at TIMESTAMPTZ NOT NULL DEFAULT NOW() ); CREATE INDEX IF NOT EXISTS idx_widget_events_widget ON genesis.widget_events(widget_id, created_at); c|iSt|ttfr|S tj|S#t t f$ricYSwxYw)z:Coerce a JSONB column (may arrive as str or dict) to dict.) isinstancerHlistjsonloads ValueError TypeError)vals rK jsonb_colrsK { #d|$ zz#  " s3AAceZdZdZdZddefdZdeefdZ deeddfd Z d e de fd Z d edee e ffd Zd edee e fdeefdZd ede dee e ffdZy)MetricsHarvesterzAPull performance data from Instantly.ai and store in Bloodstream.zhttps://api.instantly.ai/api/v2rXcx||_||_tjj dxst |_y)NINSTANTLY_API_KEY)rrXosenvironrlINSTANTLY_API_KEY_FALLBACK_instantly_keyselfrrXs rK__init__zMetricsHarvester.__init__s/  JJNN. / M3M rJrZc8tjd ddl}d|j dd}|j ||}|j|||}tjdt|d |S#t$rtj dgcYSwxYw) z Pull campaign-level analytics from Instantly.ai API v2. Returns a list of metric dicts, one per campaign. IMPORTANT: This is READ-ONLY. We never activate or unpause campaigns. z7HARVEST: Pulling email metrics from Instantly.ai API...rNz)HARVEST: 'requests' package not availableBearer application/json) Authorization Content-TypezHARVEST: Pulled metrics for campaigns) rrrequests ImportErrorerrorr_fetch_campaigns_fetch_campaign_analyticslen)rrheaders campaigns metrics_lists rKharvest_email_metricsz&MetricsHarvester.harvest_email_metricss JK   't':':&;<.  ))(G< 55hS  /L0A/B*MN!  IIA BI sA66 BBrNc`|jrtjdy|jj }|D]>}|j dd}|s|j dtj||f@|jjtjdy)z Upsert campaign-level metrics into genesis.evolution_assets for any email_template assets that belong to those campaigns. z6HARVEST [DRY RUN]: Would update metrics in BloodstreamN campaign_ida( UPDATE genesis.evolution_assets SET metrics = metrics || %s::jsonb, updated_at = NOW() WHERE asset_type = 'email_template' AND status = 'active' AND metadata->>'campaign_id' = %s z0HARVEST: Email metrics upserted into Bloodstream) rXrrrrrlrrdumpsr)rrrmrs rK#update_email_metrics_in_bloodstreamz4MetricsHarvester.update_email_metrics_in_bloodstreams << HHM N ii  /A%% r2K KK**Q-- / /  CDrJr6ctjd|dtj|}|stj d|y|j j }|jd|f|j}d}|D]=\}}t|}||} |js|jd| |f|dz }?|js|j jtjd|d ||S) z| Recalculate fitness scores for all active assets of a given type. Returns count of updated assets. z*HARVEST: Recalculating fitness scores for ...z!HARVEST: No fitness function for rz SELECT asset_id, metrics FROM genesis.evolution_assets WHERE asset_type = %s AND status = 'active' z UPDATE genesis.evolution_assets SET fitness_score = %s, updated_at = NOW() WHERE asset_id = %s zHARVEST: Updated z fitness scores for ) rrFITNESS_FUNCTIONSrlrrrrfetchallrrXr) rr6 fitness_fnrrowsupdatedr5 raw_metricsr<scores rKupdate_fitness_scoresz&MetricsHarvester.update_fitness_scoress =j\MN&**:6  KK;J<H Iii   ]   ||~%)  !Hk ,Gw'E<< X& ( qLG || II    $WI-A*NOrJrc< |j|jd|ddid}|j|j}i}|jdg|jdgzD]T}|jdxs|jd d }|jd xs|jd d }|sP|||<Vtj d t |d|S#t$r*} tjd| tdicYd} ~ Sd} ~ wwxYw)zAFetch campaign list, return {campaign_id: campaign_name} mapping.z /campaignslimitdrrparamstimeoutitemsridrrname campaign_namezHARVEST: Found rz(HARVEST: Could not fetch campaign list: z&Sunaiva Partner Outreach - AU AgenciesN) rlINSTANTLY_BASEraise_for_statusrrdebugrrrINSTANTLY_CAMPAIGN_ID) rrrresprrccidcnamers rKrz!MetricsHarvester._fetch_campaignss U<<&&'z2~  D  ! ! #99;DIXXgr*TXXfb-AA +eeDk=QUU="%=f C)C%*IcN  + III'7zB C  U KKB1#F G)+ST T Us$B:C(=*C(( D1DDDrc,t|jxstg}g}|D]7} |j|jd|d|id}i}|j dvr5|j } t| tr| jd| ni}n|j dk(rtjd|d d d i}nj|j d k(r0tjd |d d d|j|||}n+tjd|j d|d d di}t|jdxs)|jdxs|jddxsd} t|jdxs)|jdxs|jddxsd} t|jdxs)|jdxs|jddxsd} t|jdxs)|jdxs|jddxsd} t|jdxs)|jd xs|jd!dxsd}|j||j|d"| | | | |t| | t| | t| | t|| d#d#t!j"t$j'd$| dkDr;tj)d%|d d d&| d't| | d(d)t| | d(ntj)d%|d d d*:|S#t*$r&}tj-d+|d,|Yd }~gd }~wwxYw)-a Fetch analytics for each known campaign. Instantly v2 endpoint strategy: 1. GET /api/v2/analytics/campaign/count?id= Returns: total_count, open_count, reply_count, bounced_count, etc. 2. Fallback: derive from emails list (GET /api/v2/emails?campaign_id=...) NOTE: Campaign must be active and have sent emails for analytics to contain non-zero data. Paused / empty campaigns return zeros -- this is expected and handled gracefully. z/analytics/campaign/countrrr)rriz'HARVEST: Analytics API auth failed for Nz@... -- API key may lack analytics scope. Returning zero metrics.iz6HARVEST: analytics/campaign/count not found (404) for z"... -- trying email count fallbackz+HARVEST: Instantly analytics returned HTTP z for r total_count emails_sentrr open_count unique_opensopened reply_countrepliesreplied click_count unique_clicksclicked bounced_countbouncesbouncedunknownr\)rrrrrrrrcrd click_raterfrerg harvested_at HARVEST: z ... sent=z open=z.1%z reply=z[... sent=0 (campaign paused or not yet started -- zero metrics recorded, fitness unchanged)z&HARVEST: Error fetching analytics for : )rkeysrrlr status_coderrrHrrr_fetch_analytics_from_emailsrFappendrarnowAEST isoformatrrr)rrrr campaign_idsrrr campaign_datarnrrrrrrs rKrz*MetricsHarvester._fetch_campaign_analytics7s$INN,-H2G1H  'f WKe W||**++DE# +. $13 ##z1))+C.&[1553Cquu\GZ![rc3fK|])}|jds|jds&d+yw)r is_bouncedrNrrs rKrz@MetricsHarvester._fetch_analytics_from_emails..rrzHARVEST email fallback: sent=z opened=z replied=z bounced=)rrrrz HARVEST: Email fallback failed: ) rangerlrrrextendrsumrrrr)rrrr all_emailsr_rrrrrrrrrs rKrz-MetricsHarvester._fetch_analytics_from_emailss1 J!N2Y 5#. *"/=F+,||**+73#! $ ##s*yy{"-!!%(u:#!&rt!4+ 5. z?DXJXXF[Z[[G[Z[[G II/vXfXF")9WI7  $$&!(     KK:1#> ?I s%B-D0A(D E"E;EEF)r@rArBrCrrYrr r rrrDrFrrrrrIrJrKrrsK6N d tDz:ET EtE8$$$TU$U4S>U0z!%z26sCx.z dzx8!%8478 c3h8rJrc4eZdZdZddefdZdedeefdZy) AssetCullerz.Identify and archive bottom-performing assets.rXc ||_||_yNrrXrs rKrzAssetCuller.__init__  rJr6rZc tjd|d|jj}tj |i}t t|d}t t|jd}|jd|f|j}t|}|tkr%tjd|d|dtd gSg}|D]A\} } } t| } | j |d |k\s(| d kDs.|j| | d Ct|tkr'tjdt|d |dgSt|} tdt!| dz}| |z }|tkr0| tz }|d kr"tjd|dtdgS|d|}|Dcgc]}|d }}|j"r)tjdt|d|d||S|D]} |jd| f|jj%tjdt|d|d||Scc}w)z Archive bottom 10% of assets for a given type. Safety: never go below MIN_SURVIVORS_PER_TYPE active assets. Returns list of archived asset_ids. zCULL: Evaluating z assets...rrz SELECT asset_id, fitness_score, metrics FROM genesis.evolution_assets WHERE asset_type = %s AND status = 'active' ORDER BY fitness_score ASC z CULL: Only z active z assets -- skipping (minimum is )rr\)r5r:z eligible z< assets -- skipping cull (not enough data-sufficient assets)rrvzCULL: Cannot cull z without going below z survivors -- skippingNr5zCULL [DRY RUN]: Would archive  z assets: z UPDATE genesis.evolution_assets SET status = 'archived', archived_at = NOW(), archived_reason = 'alpha_evolve_cull' WHERE asset_id = %s zCULL: Archived )rrrrr"rlnextitervaluesrrrMIN_SURVIVORS_PER_TYPErrmaxrFrXr)rr6rmin_data threshold_key threshold_valr total_activeeligibler5r:rr<n cull_countremaining_after_cullto_culla culled_idss rKcullzAssetCuller.culls $ZL ;<ii '**:r:T(^V4 T(//"34b9   ]   ||~4y 1 1 HHl^8J<@((>'?qB I48 X 0Hm[ ,G{{=!, =-RUBUX VW X x=2 2 HHc(m_JzlCDD I MCDM*  !:~ "8 833JQ( 4I-..DF ;J'-45a m5 5 << HH0Z0A,i |5  # H KK      ?3z?"31ZL *VW+6s I)Nr") r@rArBrCrYrrDr r<rIrJrKr$r$s+8dQsQtCyQrJr$c leZdZdZddefdZdeefdZdede e fdZ d e dede e fd Z d e e d e ded ede e f dZ d e defdZd e defdZd e defdZdedee e fdZdedee e fdZdedee e fdZde defdZd e e dede e fdZdede efdZd e dede e fdZy) AssetMutatorzIGenerate mutations of elite assets using Gemini (or OpenRouter fallback).NrXc@||_||_||_ttj j dt|_tj j dxs1tj j dxs|j|_ y)NALPHA_EVOLVE_MUTATIONSGEMINI_API_KEYGOOGLE_API_KEY) rqdrantrXrFrrrlDEFAULT_MUTATIONS_PER_ELITEmutations_per_elite_load_gemini_key_from_genesis _gemini_key)rr qdrant_clientrXs rKrzAssetMutator.__init__Tsz #  #& JJNN35P Q$   JJNN+ , 4zz~~./ 4113 rJrZc< ddlm}|S#t$rYywxYw)z3Try to load Gemini key from genesis secrets_loader.r)get_gemini_api_keyN)rrJr)rrJs rKrFz*AssetMutator._load_gemini_key_from_genesisas%  >%' '  s  r6c |jj}|jd|f|j}|stj d|dgSt dtt|dz}g}|d|D]P}|j|dt|dt|d|d t|d t|d d Rtj d t|d|dt|d|S)z:Fetch top 10% performing active assets (by fitness score).z SELECT asset_id, fitness_score, content, version, metadata, metrics FROM genesis.evolution_assets WHERE asset_type = %s AND status = 'active' AND fitness_score > 0 ORDER BY fitness_score DESC zMUTATE: No scored z assets -- nothing to mutaterrvNrrr]r)r5r:r7r8r?r<MUTATE: z elite z assets selected (top 10% of r*) rrrrrrr0rFrrrGr)rr6rr elite_countelitesrows rK get_eliteszAssetMutator.get_elitesisii   ]   ||~ HH)*5QR SI!STT!123  % C MMF!&s1v$SV,q6%c!f-$SV,    s6{m7:,7t9+Q (  rJelitec Z|jr:tjd|jd|d|j ||Stjd|jd|dd|ddd|j |j |jd }|j|}|stjd |gS||}|j|xs|j|}|stjd |dd gS|d k(r!|Dcgc]}|j|s|}}|j||}tjdt|dt|dt!t||j|d|jScc}w)z Ask Gemini to produce N mutations of an elite asset. Each mutation is a dict with the new content + mutation metadata. Returns list of mutation dicts (may be empty on API failure). z!MUTATE [DRY RUN]: Would generate z mutations of r5zMUTATE: Generating z (fitness=r:.4fr*rzMUTATE: No mutation prompt for z.MUTATE: Both Gemini and OpenRouter failed for z -- skipping mutationsrrMz generated, z unique after dedup, returning N)rXrrrE_make_dummy_mutations_email_mutation_prompt_voice_mutation_prompt_widget_mutation_promptrlr _call_gemini_call_openrouterr_validate_email_mutation_deduplicate_via_qdrantrrm) rrRr6prompt_buildersbuilderprompt mutationsruniques rKgenerate_mutationszAssetMutator.generate_mutationss << HH3D4L4L3MN %j 124 --eZ@ @ !$":":!;< #$Ju_/Ec.J! M #99 77!99  "%%j1 KK9*F GI%%f-N1F1Fv1N  II@$%%;= I ) )$-Rq1N1Nq1QRIR--iD s9~&l3v;-@&&)#f+t7O7O&P%Q S /t//00Ss F(4F(r`parentrNc r|jr,t|Dcgc]\}}d|d|d|d|dc}}S|jj}g}t|D]\}} d|d|ddj d|ddt j jdd } |jd | |d|tj| |d |f|j| |d|| |d d |jjtjd t|d|Scc}}w)z Write mutation records into genesis.mutation_test_results for testing. Returns list of stored records with mutation_id assigned. DRY_r!03dr5) mutation_idr9mutationMUT_NraD INSERT INTO genesis.mutation_test_results (mutation_id, parent_id, asset_type, mutation_content, parent_fitness, cycle_id, status, created_at) VALUES (%s, %s, %s, %s, %s, %s, 'pending', NOW()) ON CONFLICT (mutation_id) DO NOTHING r:)rgr9r6rhparent_fitnesszMUTATE: Stored z+ mutations in genesis.mutation_test_results)rX enumeraterrupperuuiduuid4hexrrrrrrrr) rr`rcr6rNirrstoredrhrgs rKstore_mutationszAssetMutator.store_mutationssr <<&i0  Aq &*(1QsG# casual spectrum 7. Length: shorter (under 80 words) or longer (up to 200 words) variants 8. Urgency: add/remove scarcity or time pressure CONSTRAINTS (HARD RULES -- must not be violated): - Keep ALL {{variable}} merge tags intact and spelled correctly - Must comply with Australian Spam Act 2003 -- include [Unsubscribe] at the end - Must be truthful (no fabricated statistics or fake testimonials) - Maximum 200 words per email body - EACH mutation must differ meaningfully from the parent (not just a word swap) - Do NOT reproduce the parent verbatim in any mutation OUTPUT FORMAT -- JSON array ONLY, no markdown, no prose: [ { "subject_line": "...", "body": "...", "mutation_dimensions": ["tone", "cta"], "mutation_rationale": "Shifted to casual tone with reply-based CTA" } ]rlrrrErrRr7s rKrVz#AssetMutator._email_mutation_prompts "449/4J33OP ++ne , -.VU::eii 26qABC "5567)) rJc |d}d|ddd|jdddtj|jd id d |jd S)Nr7zhYou are Alpha Evolve, optimising AI voice agent system prompts for Telnyx. ELITE PARENT (fitness_score=r:rT): system_promptrv Metrics: r<rLrx YOUR TASK: Generate exactly ah MUTATED versions. MUTATION DIMENSIONS: 1. Greeting style: formal vs warm vs direct 2. Question ordering: change discovery sequence 3. Objection handling: different rebuttal strategies 4. Booking CTA timing: earlier vs later in conversation 5. Verbal padding phrases: different natural stall tactics 6. Personality warmth: adjust empathy markers 7. Information density: more/less detail per response 8. Closing technique: different ways to secure the booking CONSTRAINTS: - Maintain brand identity (Australian, professional, helpful) - Include booking/scheduling capability - Handle price, timing, "just looking" objections - Maximum 2000 characters for system prompt OUTPUT FORMAT -- JSON array ONLY: [ { "system_prompt": "...", "mutation_dimensions": ["greeting", "booking_timing"], "mutation_rationale": "Earlier booking CTA with warmer greeting" } ]rzr{s rKrWz#AssetMutator._voice_mutation_promptsu ""?3C89_e$%& **UYYy"-a 8 9:!5567  rJc |d}|jd|}d|dddtj|dd tj|jd idd |jd S) Nr7configzdYou are Alpha Evolve, optimising website widget configurations. ELITE PARENT config (fitness_score=r:rTr}rLrxrr<ra config variants. MUTATION DIMENSIONS: 1. Greeting text: different opening messages 2. CTA text: different button labels 3. Auto-open delay: timing variations 0-15000ms 4. Position: bottom-right vs bottom-left 5. Theme colour: variations within brand palette 6. Voice selection: different Telnyx NaturalHD voice names CONSTRAINTS: - Must include greeting, CTA text, and position - Colours must be valid hex codes - auto_open_delay_ms between 0 and 30000 - voice_id must be valid Telnyx NaturalHD voice name OUTPUT FORMAT -- JSON array ONLY: [ { "config": {"greeting": "...", "theme_color": "...", ...}, "mutation_dimensions": ["greeting", "auto_open_delay"], "mutation_rationale": "Shorter delay with more casual greeting" } ]rz)rrRr7rs rKrXz$AssetMutator._widget_mutation_promptCs "Xw/$$)/$:3#?@F1 **UYYy"-a 8 9:!5567 rJr_c|jstjdy ddlm}|j |j|j t}|j||jjddd }|jj}|j|S#t$r"}tjd |Yd}~yd}~wwxYw) z0Call Gemini generative API to produce mutations.z#MUTATE: No Gemini API key availableNrapi_key? r) temperaturemax_output_tokensresponse_mime_type)generation_configzMUTATE: Gemini call failed: )rGrrgoogle.generativeai generativeai configureGenerativeModelGEMINI_MUTATION_MODELgenerate_contenttypesGenerationConfigtextstrip_parse_mutation_jsonr)rr_genaimodelresponsernrs rKrYzAssetMutator._call_geminijs KK= >  / OOD$4$4O 5))*?@E--"'++">"> #&*'9#?#.H--%%'C,,S1 1  KK6qc: ; sBB55 C >CC c tjjd}|stj dy ddl}|j dd|ddd d d d d dd|dgdddd}|j|jdddd}|j|S#t$r"}tj d|Yd}~yd}~wwxYw)zAFall back to OpenRouter (Kimi K2.5 / MiniMax M2.5) for mutations.OPENROUTER_API_KEYz6MUTATE: OPENROUTER_API_KEY not set -- cannot fall backNrz-https://openrouter.ai/api/v1/chat/completionsrrzhttps://sunaivadigital.comzAlpha Evolve Daemon)rrz HTTP-RefererzX-Titlezmoonshotai/kimi-k2-5systemzYou are Alpha Evolve.)roler7rrr)rmessagesr max_tokens<)rrrchoicesmessager7z$MUTATE: OpenRouter fallback failed: ) rrrlrrrpostrrrr)rr_rrrr7rs rKrZzAssetMutator._call_openrouters**..!56 KKP Q  ==?'.wi%8$6$@4 4!)6MN!'F;!$'"&#!D&  ! ! #iik),Q/ :9EG,,W5 5  KK>qcB C sA*B$$ C-C  Crnctjdd|jtj}tjdd|jtj} t j |}t |tr|St |tr|jd|gSy#tj$r=}tjd|tjd|dd Yd}~yd}~wwxYw) z?Extract a JSON array from LLM output (handles markdown fences).z^```(?:json)?\s*r)flagsz\s*```$r`Nz+MUTATE: Could not parse LLM JSON response: zMUTATE: Raw response was: i,)resubr MULTILINErrrrrHrlJSONDecodeErrorrrr)rrnparsedrs rKrz!AssetMutator._parse_mutation_jsonsff("ciikNffZSYY[ E ZZ_F&$' &$'zz+x88##  KKEaSI J II23t9+> ? s,&B7"B77D 3DDrhc|jdd}|jdd}|r|stjdyt|j }|dkDrtjd|dyd |j vr|j d z|d<||fD]B}|jd }|jd }||k7s-tjd yy)z Validate that an email mutation meets hard constraints. Returns True if valid, False if it should be rejected. rurrwz4MUTATE: Rejected mutation -- missing subject or bodyFz,MUTATE: Rejected mutation -- body too long (z words)z [unsubscribe]z [Unsubscribe]z{{z}}z8MUTATE: Rejected mutation -- mismatched merge tag bracesT)rlrrrsplitlowerrstripcount)rrhsubjectrw word_countr open_braces close_bracess rKr[z%AssetMutator._validate_email_mutations ,,~r2||FB'd IIL M&   IIDZLPWX Y $**, .#{{}/BBHV t_ E%%++d+K&5;;t,Ll* TV  rJc|js|Sg}|D]}tj|d} ddlm}m}m}|jjd|j|dt||d|| g  } | s|j|n'tjd | djd d|S#t$r4} tjd| d|j|Yd} ~ d} ~ wwxYw)z Use Qdrant semantic similarity to reject near-duplicate mutations. Skips gracefully if Qdrant is unavailable. T) sort_keysr)FilterFieldCondition MatchValuealpha_evolve_assetsrr6)value)keymatch)must)collection_name query_vectorrscore_threshold query_filterz,MUTATE: Rejected near-duplicate (similarity=z.3fr*zMUTATE: Qdrant dedup error: z -- accepting mutationN)rCrrqdrant_client.modelsrrrsearch _embed_textSIMILARITY_THRESHOLDrrrrrr) rr`r6rarhrrrrresultsrs rKr\z$AssetMutator._deduplicate_via_qdrants {{ ! (H::h$7D (SS++,,$9!%!1!1$!7$8!'*$0&0z&B" - MM(+II''.qz'7'7& *C99C>rc ddlm}|jr4|j|j|j d|}|dS dgdzS#t $rYwxYw) z,Generate embedding vector for deduplication.rNrzmodels/text-embedding-004)rr7 embeddingr\i)rrrGr embed_contentr)rrrresults rKrzAssetMutator._embed_textsv  /(8(89,,5 -k**  us{   sAA AAc B|dk(rkt|jDcgc]L}d|dzd|djddd|dzd |djd d d d ddgd|dzdNc}St|jDcgc]}d|d c}Scc}wcc}w)z.Return placeholder mutations for dry-run mode.rz[DRY RUN] Variant rrr7rurvz[DRY RUN mutation z] rwrNrz... [Unsubscribe]tonezDry-run dummy variant )rurwmutation_dimensionsmutation_rationaleT)rXvariant)rrErl)rrRr6rqs rKrUz"AssetMutator._make_dummy_mutationss ) )t778 '91Ri@P@T@TUcej@k?l$m01Ri8H8L8LVUW8XY\Z\8]7^^rs,28,B1Q3%*H  :?t?W?W9XYADQ/YYZs AB BNF)r@rArBrCrYrr rDrFr r rQrbrsrVrWrXrYrZrr[r\rGrrUrIrJrKr>r>QsS  $  x}ST$Z@1111#11$t*11f0d0-10?B0NQ0 d0l+D+S+Z"D"S"H!T!c!N38DJ+?. s xT /C Dd0D*  $ L(d(14( d(T  U & Z4 ZS ZT$Z ZrJr>c eZdZdZddefdZdeededededeef d Z d ed ededefd Z d ed ededefd Z d ed ededefdZ deede dededdf dZy)MutationTesterz Phase 1: Generate Jules Pro task descriptions for manual submission. Phase 2+: Auto-submit via Jules API when available. rXcN||_||_tjddy)NTr))rrXJULES_TASKS_DIRmkdirrs rKrzMutationTester.__init__4s#  dT:rJstored_mutationsrcr6rNrZc|sgSg}|j|j|jd}|j|}|sgS|D]#}||d|d|} |j | %t j tjd} td|d|d| dz } |j|| |||jrdnd } tjd | d t|d | |S) z Generate Jules Pro task descriptions for each mutation. Writes markdown file to hive/jules_evolve_tasks/. Returns list of task dicts. rrgrhz %Y%m%d_%H%M jules_tasks_r!.mdz [DRY RUN] rzTEST: z Generated z Jules tasks -> )_email_test_task_voice_test_task_widget_test_taskrlrrr r strftimer_write_tasks_filerXrrr) rrrcr6rNtasks task_buildersr^recordtask timestamp output_filemodes rKgenerate_test_tasksz"MutationTester.generate_test_tasks9s I"33 11!33  ##J/I& F}%z"D LL   LL&// > 8*Aj\9+S A B  uk8ZH#||| 6$z#e*5Ek]ST rJtask_idrhc||jdi}|d|jddddd|d|d d |d d d |jddd|jddddd|jddd|jdgd|jddd|jddddd|d d ddS)Nr7zTest email mutation: rrmediumrz=# Alpha Evolve Mutation Test -- Email Template **Task ID**: z **Parent ID**: r5 **Parent fitness**: r:rTz+ ## Parent (current winner) **Subject**: rurvz **Body**: ``` rwz ``` ## Mutation **Subject**: z **Dimensions changed**: r **Rationale**: a ``` ## Test Instructions 1. Load 10 representative Australian agency lead profiles (job title, location, agency type) 2. Use Gemini Flash to role-play as each lead persona and predict: - Would they open this email? (Yes/No + confidence 0-1) - Would they reply? (Yes/No + confidence 0-1) - What objection would they raise? 3. Calculate predicted open_rate, reply_rate 4. Apply `email_fitness()` to compute predicted_fitness_score 5. Compare against parent fitness of a 6. Write result to genesis.mutation_test_results table: - Set `mutation_fitness` = predicted score - Set `test_verdict` = 'win' | 'lose' | 'inconclusive' - Set `status` = 'completed' ## Acceptance Criteria - [ ] 10 persona simulations completed - [ ] predicted_fitness_score calculated using email_fitness() - [ ] Comparison against parent documented - [ ] Result written to genesis.mutation_test_results (status='completed') rtitlepriorityestimated_minutes descriptionrrrrhrcparent_contents rKrzMutationTester._email_test_taskjs, Ir2,X\\:NPY-Z,[\ !" Yz"#$O,S12  7 89FE"4C()* ll>51 23!&;R@AB 159:; feTc"# $&'-_&=c%B CG/ 5 5 rJc|jdi}|d|jddddd|d|d d d |jd d ddd|jdgd|jdd d|jd d ddd dS)Nr7zTest voice prompt mutation: rrrrz;# Alpha Evolve Mutation Test -- Voice Prompt **Task ID**: rr:rTz( ## Parent system prompt (excerpt) ``` r~rvrz%... ``` ## Mutation **Dimensions**: rrz ``` a... ``` ## Test Instructions 1. Load 5 historical call transcripts from genesis.call_insights 2. Simulate 5 conversations using Gemini Flash as caller persona 3. Track: call duration, booking attempt, sentiment score 4. Apply voice_fitness() to compute predicted_fitness_score 5. Compare vs parent, write result to genesis.mutation_test_results ## Acceptance Criteria - [ ] 5 simulations completed - [ ] Predicted fitness score calculated - [ ] Result written to genesis.mutation_test_results rrrs rKrzMutationTester._voice_test_tasks Ir23HLLAUW`4a3bc !" YO,S12OU+DS1233R89: 159:; ou%ds+,- $ $ rJc |d|jddddd|d|dd d tj|jd id dddtj|jd|d ddd|jdgd dS)NzTest widget config mutation: rrlowrz<# Alpha Evolve Mutation Test -- Widget Config **Task ID**: rr:rTz ## Parent config ```json r7rLrxrz! ``` ## Mutation config ```json rz ``` **Dimensions**: ra ## Test Instructions 1. Evaluate UX principles (contrast ratio, CTA visibility, timing) 2. Score predicted interaction_rate and lead_capture_rate 3. Apply widget_fitness() for predicted_fitness_score 4. Compare vs parent, write result to genesis.mutation_test_results r)rlrr)rrrhrcs rKrz MutationTester._widget_test_tasks4X\\BVXa5b4cd!" YO,S12FJJy" %a0#678 HLL8 ,Q7=>?3R89:   rJrrNc jd|dd|dtjtjdt |ddt ddd dg }|dt D]7}|j d |d d |d d|dd|ddd|ddd dg9|jdj|dy)Nz(# Jules Pro Tasks -- Alpha Evolve Cycle rz**Asset Type**: z**Generated**: z **Tasks**: z'**Submit at**: https://jules.google.comz**Cycle budget**: z tasks max this cyclez---z## rrrz**Priority**: rz**Estimated**: rz minutesr r,r-) rr r r rMAX_JULES_TASKS_PER_CYCLEr write_textjoin)rrrrNr6linesrs rKrz MutationTester._write_tasks_files7xj A zl +hll40::<= >#e* &5 !: ;;P Q     445 D LLd9o&bg8 j!1 23!$':";!ACORC CrJrcHeZdZdZd defdZdedeefdZ ded ede fd Z y) AssetPromoterz Compare mutation test results against parents. Promote winners. Discard losers. Phase 1: Checks results populated by Jules from the PREVIOUS cycle. NrXc.||_||_||_yr&)rredisrX)rr redis_clientrXs rKrzAssetPromoter.__init__s !  rJrNrZc xtjd|jj}|j d|j }|stjdgStjdt |dg}|D]0}|\}}}} } } } t| xsd} t| xsd} t| }| | krAtjd|d| dd | dd |js|j d |f}| d kDr| | z | z nd }tjd|d| dd| dd|dzdd |jr|j||||tk\d|j|||}|d|}|j d|f|j}|rt|d ni}|j d||tj|||| tj|f|j d||f|j d||f|j rs d|d|}|j j#|tj|d|j j%d|d|tj'd||j|||||tk\d!3|js|jj-tjdt |d"|S#t($r"}tj+d|Yd }~d }~wwxYw)#z Find completed mutation test results with no promotion decision yet. Promote mutations that beat their parent. Discard losers. Returns list of promotion records. z7ASCEND: Checking for completed mutation test results...aJ SELECT mutation_id, parent_id, asset_type, mutation_fitness, parent_fitness, mutation_content, test_verdict FROM genesis.mutation_test_results WHERE status = 'completed' AND promoted IS NULL ORDER BY (COALESCE(mutation_fitness, 0) - parent_fitness) DESC z5ASCEND: No completed tests pending promotion decisionzASCEND: z completed tests to evaluater\z lost (rTz <= z) -- discardingz UPDATE genesis.mutation_test_results SET promoted = FALSE, evaluated_at = NOW() WHERE mutation_id = %s rrjz BEATS parent (z > z, +r.1fz%))rgr9 improvementis_major_vz_ SELECT metadata FROM genesis.evolution_assets WHERE asset_id = %s aJ INSERT INTO genesis.evolution_assets (asset_id, asset_type, content, version, parent_id, fitness_score, status, metrics, metadata, created_at) VALUES (%s, %s, %s, %s, %s, %s, 'active', '{}', %s, NOW()) ON CONFLICT (asset_id) DO NOTHING z UPDATE genesis.evolution_assets SET status = 'superseded', superseded_by = %s, updated_at = NOW() WHERE asset_id = %s z UPDATE genesis.mutation_test_results SET promoted = TRUE, promoted_asset_id = %s, evaluated_at = NOW() WHERE mutation_id = %s z active_asset::iQ)exz ASCEND: Redis cache updated for z#ASCEND: Redis cache update failed: N)rg new_asset_idr9rrz promotions this cycle)rrrrrrrrGrrXrMAJOR_IMPROVEMENT_THRESHOLD_get_next_versionfetchonerrrsetdeleterrrr)rrNrrrUrPrgr9r6raw_mut_fitnessrk raw_content test_verdictmutation_fitnessmutation_contentr new_versionr  parent_rowparent_metadata cache_keyrs rKevaluate_and_promotez"AssetPromoter.evaluate_and_promote"s JKii    ||~ HHL MI 8CI;&BCD e CKN I[)Z nk<$_%;< ">#8S9N(5 >1{m,(-T.1E_V||KK!& ) "A%"N2nD+.  HH;-($S)^C,@AOC(,  ||!!#.!*#. +/J J # 00JLK'[;-8L KK J:Di 1 6"O KKj +,Y  ?+   KK  *  , KK  ,  .zzK"/ |1\N KIJJNN!4::.>#?E#JJ%% j\9+&NOII @OP   * ,&*'+FF  e N|| II    8C O,,BCD!KKK"EaS IJJKs1A2L L9L44L9r9r6cd|jd|||f|j}|dxsddzS)Nz SELECT MAX(version) FROM genesis.evolution_assets WHERE (asset_id = %s OR parent_id = %s) AND asset_type = %s rr)rr )rr9r6rrPs rKr zAssetPromoter._get_next_versions?  J /  1 llnA !q  rJr) r@rArBrCrYrrDr r rrFr rIrJrKrrsH CSCT$ZCJ!3!C!!rJrcneZdZdZd defdZdeddfdZdeddfdZdeddfd Z deddfd Z deddfd Z y) CycleLoggerz5Record evolution cycle results to Bloodstream and KG.rXc ||_||_yr&r'rs rKrzCycleLogger.__init__r(rJreportrZNcftjd|jd|js|j ||j dkDr|j ||j||jr|j|tjd|jdy)zCWrite cycle report to PostgreSQL, KG axiom file, and markdown file.zLOG: Recording cycle rrz LOG: Cycle z recorded successfullyN) rrrNrX_write_to_postgresrU_write_kg_axiom_write_report_filerV_notify_major_improvements)rrs rK log_cyclezCycleLogger.log_cycles ((9=>||  # #F +   q   ( '  $ $  + +F 3 ;v//EFGrJc|jj} |jd|j|j|j |j |j|j|j|jtj|jtj|j|jt f |jj#t$j'dy#t($r<}|jj+t$j-d|Yd}~yd}~wwxYw)Na INSERT INTO genesis.evolution_cycles (cycle_id, started_at, completed_at, assets_scored, assets_culled, mutations_generated, mutations_tested, promotions, major_improvements, errors, dry_run, cycle_version) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) ON CONFLICT (cycle_id) DO UPDATE SET completed_at = EXCLUDED.completed_at, assets_scored = EXCLUDED.assets_scored, assets_culled = EXCLUDED.assets_culled, mutations_generated = EXCLUDED.mutations_generated, mutations_tested = EXCLUDED.mutations_tested, promotions = EXCLUDED.promotions, major_improvements = EXCLUDED.major_improvements, errors = EXCLUDED.errors z5LOG: Cycle record written to genesis.evolution_cyclesz*LOG: Failed to write cycle to PostgreSQL: )rrrrNrOrPrQrRrSrTrUrrrVrWrX CYCLE_VERSIONrrrrrr)rrrrs rKr zCycleLogger._write_to_postgressii " H KK !!##$$$$**''!! 6445 6==)  : II    HHL M H II   IIB1#F G G HsC%D E 2EEc ^d|jd|jd|jd|jd|jd|jd |j rdt |j d nd zd d d d|jd} tttdd5}|jtj|dzdddtjdty#1swY&xYw#t $r"}tj#d|Yd}~yd}~wwxYw)zDAppend an axiom to KNOWLEDGE_GRAPH/axioms/alpha_evolve_daemon.jsonl.zAED-zAlpha Evolve Daemon cycle z : Scored z assets, culled z , generated z mutations, promoted z winners. zMajor improvements: .z!No major improvements this cycle.zscripts/alpha_evolve_daemon.pygGz? evolutionalpha_evolve_daemon)raxiomsourcerocategorydomainrr:r,r-rNzLOG: KG axiom written to zLOG: Failed to write KG axiom: )rNrQrRrSrUrVrrPopenrDKG_AXIOMS_FILEwriterrrrrr)rrr+frs rKr!zCycleLogger._write_kg_axioms7)*,V__,=> ..//?@T@T?UV#7789"--.j: 00+3v/H/H+I*J!L<7#+,,# & =c.)3A 2Q 5)D01 2 HH00@A B 2 2 = II7s; < < =s0 D((C5$D5C>:D D, D''D,ctjddtd|jdz }|jrdnd}d|j|d|jd |j d |jd t d |jd |jd|jd|jd|jdt|jdt|jd}|jre|jD]U}|d|jd|jddd|jdddzdd|jdddz }Wn|d z }|jr|d!z }|jD] }|d"|dz } |d#t d$z } |j!|d%&t"j%d'|y)#t&$r"}t"j)d(|Yd)}~y)d)}~wwxYw)*z+Write human-readable markdown cycle report.Tr) alpha_evolve_rz (DRY RUN)rz# Alpha Evolve Cycle Report: z **Started**: z **Completed**: z **Dry Run**: z **Version**: zF ## Results | Metric | Value | |--------|-------| | Assets Scored | z | | Assets Culled | z | | Mutations Generated | z& | | Mutations Tested (Jules tasks) | z | | Promotions | z! | | Major Improvements (>20%) | z | | Errors | z | ## Major Improvements z- **r rgrz**: +rrrrz% over parent r9rz_None this cycle._ z ## Errors z- z+ --- _Generated by alpha_evolve_daemon.py vz_ r,r-zLOG: Cycle report written to z"LOG: Failed to write report file: N) PROGRESS_DIRrrNrXrOrPr&rQrRrSrTrUrrVrWrlrrrrr)rr report_filedry_tagr7imperrrs rKr"zCycleLogger._write_report_filesD4$7"}V__4ES%II "(..,b3FOO3DWIN !##$%nn _ ''()''()3345$$*$;$;#<=!!"#"6#<#<=>?    #,  $ $00 377>377=)3TUVW q1#5c:.ww{I67r;  - -G == ( (G}} (RuB<' ( B=/QTUU @  " "7W " = HH4[MB C @ II:1#> ? ? @s+G G2G--G2ctjdt|jd t t t dd5}|jD]p}|jd|jdd}|jd |jd |d |jd dd |jdddzdd r dddy#1swYyxYw#t$r"}tjd|Yd}~yd}~wwxYw)z Phase 1: Write major improvements to notification log file. Phase 2: Send Telegram via AIVA bot. Phase 3: Email via Instantly.ai to kinan@protonmail.com. zLOG: z MAJOR improvements detected!r:r,r-r rgr[z ] MAJOR: z beats r9z by rrrrz% Nz-LOG: Failed to write major improvements log: ) rrrrVr/rDMAJOR_IMPROVEMENTS_LOGrlr1rPrr)rrr2r8r5rs rKr#z&CycleLogger._notify_major_improvementsBs  5V66788UVW Kc013I Q!44C"ww~sww}i7XYHGGF//0 (D!!$i!@ AB!ggmQ7;C@E    K IIEaSI J J Ks6C BC CCCC D (DD r") r@rArBrCrYrrMr$r r!r"r#rIrJrKrrs~?dH HH"$H$H$HL=k=d=81@1@1@fKKKrJrcv|j}tdtdtd|jd|j}|rtdtdddd d d d d d d ddd dd td|D]J}td|ddd |dd d |dd d t |dxsddd t |dxsdd Lntdtd|jd|j}|rtdt |dtddd d ddd d d d d!d d d"d d d#d$d d%d$td&|D]S}td|dd d t |dd'd(dd |dd d |dd d |dd d |d)d$d t |d*d$Un td+|jd,|jd}|jd-|jd}td.td/|td0|ty')1z*Print current generation status to stdout.= ============================================================z(ALPHA EVOLVE DAEMON -- Generation Status<============================================================a  SELECT asset_type, status, COUNT(*) as cnt, AVG(fitness_score) as avg_fitness, MAX(fitness_score) as max_fitness FROM genesis.evolution_assets GROUP BY asset_type, status ORDER BY asset_type, status z Assets by type/status:z z Asset Typez<20r+Statusz<12Countz>6z Avg Fitnessz>12z Max FitnesszB ----------------------------------------------------------------rrrLrz>12.4fr]z+ No assets in genesis.evolution_assets yet.zGRun --cycle --seed to populate from INSTANTLY_SEQUENCE_PARTNER_PITCH.mdz SELECT cycle_id, started_at, assets_scored, assets_culled, mutations_generated, promotions, dry_run FROM genesis.evolution_cycles ORDER BY started_at DESC LIMIT 10 z Recent cycles (last z):zCycle IDStartedz<25ScoredCulledMutsPromotedz>8DryRunzM ---------------------------------------------------------------------------Nrrjz No evolution cycles run yet.za SELECT COUNT(*) FROM genesis.mutation_test_results WHERE status = 'pending' zx SELECT COUNT(*) FROM genesis.mutation_test_results WHERE status = 'completed' AND promoted IS NULL z Mutation pipeline:z Pending Jules tests: z Awaiting ASCEND: )rprintrrrGrrDr )rrrrcyclesrpendingawaiting_ascends rK show_statusrNZs ++-C / 45 (OKK  <<>D  () <$Ahs^1WRL-PSATTUVcdgUhij o A QqT#Ja!Sz1Q4)11#F+1U1Q491-=f,EG   <= WXKK \\^F  &s6{m267 C )Cm1XbM6"+Qz"oQxPRm U  o A QqT#JaAaD #2s31Q4)1QqT"IQqtBiq1b 3qt9R.J   ./KK llnQGKK llnQ'O " %gY /0 %o%6 78 GrJrXcVtdz dz dz }|jstjd|y|j d}t j d|d d }t|}|stjd t}|j}d}|D]}|r!tjd |d |d z }& |jd|d tj|dtjt|jdd |jdddf|j dkDr|d z }|s|j%tjd|d|S#t"$r(} tjd|d d| Yd } ~ d } ~ wwxYw)a  Seed genesis.evolution_assets with the 5 email steps x 2 subject variants from data/LEADS/INSTANTLY_SEQUENCE_PARTNER_PITCH.md. This is a one-time bootstrap operation. Existing assets are not overwritten. Returns count of newly inserted assets. rLEADSz#INSTANTLY_SEQUENCE_PARTNER_PITCH.mdz!SEED: Sequence file not found at rr,r-z(?m)^## EMAIL \d+:rNz._ArgsFN)r@rArBrXforcer6seedrIrJrK_ArgsrvQs! rJryzDAEMON: Cycle failed: exc_info)rrrr r replacer total_secondsr timesleepKeyboardInterrupt run_cyclerr)r next_run sleep_secondsryrs rKrun_daemon_loopr2sU HH BCHH IJHH +, ll4 ;;Aaq;I (?  q) )H!C668   d 237x!!#$ &   JJ} % (d);)E)E)G(HIJ C   eg 9 !  HH< =   C II.qc2TI B B Cs*D2E2EE FE>>Fc Ntjjddjdk(r#t |ddst j dyt |ddxs1tjjd djdk(}|rt j d tjtjd }tjtj}t j d t j d td|t j d|t j d|t j dt j d g}d}d}d}d}g} t} t!| t |ddr t#| |d} ddlm} ddl}|j*dIi| j-} | j/t j dd} ddlm}ddlm}|dIi|j;}t j dt=| |}t?| |}tA| ||}tC| |}tE| | |}tG| |}t |dd}|r|g}ntH}|D]U}t j d d!t j d"|t j d! t j d#|d$|d%k(r#|jK}|r|jM||jO|| jQ}|jSd&|f|jUd}||z }t j d'|d(|d)t j d*|d$|jW|}|tY|z }t j d+|d$|j[|}g} |D]J}!|j]|!|}"|"s|j_|"|!||}#| ja|#|tY|#z }Lt j d,|d$| r|r|D cic]} | d-|  }$} i}%| D](}&|&d.}'|%jc|'gje|&*|%jgD]=\}(})|$j|(|(d/id0}*|ji|)|*||}+|tY|+z }?Xt j d5 |jm|}-| ja|-t j d7tjtj}.| D/cgc]}/|/jd8s|/}0}/to|||.||||tY| |0||9 }1|jq|1t j d:t j d;|d<t j d=|t j d>|t j d?|t j d@|t j dAtY| t j dBtY|0t j dCtY|t j dD|t j dE|dF|.t j d |r1t j dGt j dHtr | ju|1S#t$r"} t jd| Yd} ~ yd} ~ wwxYw#t0$r$} t j3d| dYd} ~ d} ~ wwxYw#t0$r$} t j3d| dYd} ~ d} ~ wwxYwcc} w#t0$r\} d1|d2| },t j|,d34|je|, | jkn#t0$rYnwxYwYd} ~ d} ~ wwxYw#t0$r8} d6| },t j|,d34|je|,Yd} ~ Cd} ~ wwxYwcc}/w#t0$rY|1SwxYw)Jz7Execute one complete Alpha Evolve cycle (all 6 phases).ALPHA_EVOLVE_PAUSErtruerwFzGAlpha Evolve PAUSED (ALPHA_EVOLVE_PAUSE=true). Use --force to override.NrXALPHA_EVOLVE_DRY_RUNz/=== DRY RUN MODE -- No changes will be made ===z %Y%m%d_%H%M%Sr?zALPHA EVOLVE DAEMON vz -- Cycle z Started: z Dry Run: z"Phase: 1 (email templates only)rzFATAL: rx)rX) RedisConfigzRedis connectedzRedis unavailable: z$ -- continuing without cache updates) QdrantClient) QdrantConfigzQdrant connectedzQdrant unavailable: z% -- continuing without semantic dedupr6rz(========================================z Processing: z--- Phase 1: HARVEST (z) ---rz SELECT COUNT(*) FROM genesis.evolution_assets WHERE asset_type = %s AND status = 'active' AND fitness_score > 0 rr+z assets with fitness > 0z--- Phase 2: CULL (z--- Phase 3: MUTATE (z--- Phase 4: TEST (r5r9r\)r5r:r7zError processing rTrzz --- Phase 5: ASCEND ---zASCEND phase error: z --- Phase 6: LOG ---r) rNrOrPrQrRrSrTrUrVrWrXr>zALPHA EVOLVE CYCLE z COMPLETEz Assets Scored: z Assets Culled: z Mutations Generated:z Jules Tasks Created:z Promotions: z Major (>20%): z Errors: z Dry Run: z Duration: z -> z7DRY RUN complete. No changes were made to the database.zJules tasks (for review): rI);rrrlrgetattrrrrr r rr r&rrrrr[rrrRedisrpingrrrHrrget_client_paramsrr$r>rrrPHASE_1_ASSET_TYPESrrrrrr r<rrQrbrsr setdefaultrrrrrrMr$rclose)2argsrXrNrOrW total_scored total_culledtotal_mutations total_testedpromotions_listpg_connrrr redis_librHrr harvestercullermutatortesterpromoterloggerrequested_type asset_typesr6rr scored_countr;rOall_stored_mutationsrR raw_mutationsrr parent_map by_parentrpidr9parent_mutationsrcrerr_msgrUrPprVrs2 rKrr`s  zz~~*B/5576A'RVX_afJg  ' dIu- -r288:fD  BC||D!**?;Hd#--/JHHXHH$]O:hZ HIHHz* &'HHz' #$HH13HHXFLLOL"$O #% 'tVU#!'7;LS.!&yM)J)J)LM  "# MU./$H|'E'E'GH  #$!'2I ' *F7M7;G GW -FWlG>@ AA,O  + +J 7.."C KK <<>!,L L (L HHya |;ST U HH*:,e< =Z0J C O +L HH,ZL> ?'' 3F/1  / ' : :5* M $ 00!5*h%++F33v;. / HH*:,e< =#IO.PAq}a/?.P .P35 - ?@HH%c&k] 34HH%gY /0HH%j\l^ DEHHX JK -o->?@   Mu  GA3- & S )!,PQRRS U *1#-RSTTUT/Q )*Rs;G IIgI - MM' "   "     (, 'D ) gKR   M s ]A^7^1E=_&> _! B_&%"abbb ]>]99]> ^. ^))^.1 _:__!_&& a /0a `10a1 `=:a<`==aa  b-b  b b$#b$cFtjdtjd}|jd}|j ddd |j d dd |j d dd |j ddd |j ddd |j dt dd|j ddd |j }|jr2 t}t|t||jy|j"r t%yt'|}|r#|j(rtj dyyy#t$r7}tjd|tj dYd}~yd}~wwxYw)NzFAlpha Evolve Daemon -- Autonomous nightly evolution for Genesis assetsa Examples: python scripts/alpha_evolve_daemon.py --dry-run # Simulate without changes python scripts/alpha_evolve_daemon.py --cycle # Run one evolution cycle python scripts/alpha_evolve_daemon.py --cycle --seed # Seed + run cycle python scripts/alpha_evolve_daemon.py --status # Show generation status python scripts/alpha_evolve_daemon.py --daemon # Run as daemon (03:00 AEST) Environment vars: INSTANTLY_API_KEY Override hardcoded Instantly key GEMINI_API_KEY Gemini key for LLM mutations OPENROUTER_API_KEY Fallback LLM if Gemini unavailable ALPHA_EVOLVE_PAUSE=true Pause the daemon ALPHA_EVOLVE_DRY_RUN=true Force dry-run mode ALPHA_EVOLVE_MUTATIONS=N Mutations per elite (default 5) )rformatter_classepilogT)requiredz--cycle store_truez Run one complete evolution cycle)actionhelpz --dry-runzASimulate a cycle without making any changes (safe to run anytime)z--statusz*Show current generation status (read-only)z--daemonz6Run as long-running daemon (fires at 03:00 AEST daily)z--forcez#Override ALPHA_EVOLVE_PAUSE env varz --asset-typer6z9Process only this asset type (default: all Phase 1 types))rdestrz--seedzQSeed initial email assets from INSTANTLY_SEQUENCE_PARTNER_PITCH.md before cyclingz$STATUS: Cannot connect to database: r)argparseArgumentParserRawDescriptionHelpFormatteradd_mutually_exclusive_group add_argument ASSET_TYPES parse_argsr;rrrNrrrrsysexitdaemonrrrW)parser mode_grouprrrrs rKmainrJ s  $ $\ << F*44d4CJ, /L P< 9< E  , 2  , H  `    D  {{ $&D $    JJL  {{t_F &--   v  IIrrrrNrYr[rSrTrrrr@rIrJrKrs$L  002233 H~%%'..55 "V+.>>3|$%3*+,  #$ "U ((rl"B'#S) 2T#tCH~-.?c(  & (f$z1 '*>> 11H3H3H I*BHHTDH)* ,, @C*< <=Pcjj)g'  ; ;  ;     &;5; &4S> &e &F &4S> &e &F&DcN&u&$$!#H@T.Y x c  L XX~VZVZz`C`CNY!Y!@^K^KJE X<T<c<~ S d4j F#T #T'C\cx ,cTM` zFrJ