0 AND finished_at IS NOT NULL ORDER BY julianday(started_at) DESC LIMIT 4`);\n const hrows:any[]=rh.rows||[];\n const hLaunched=hrows.reduce((s:number,x:any)=>s+Number(x.launched||0),0);\n const hComplete=hrows.reduce((s:number,x:any)=>s+Number(x.complete||0),0);\n const healthRate=hLaunched?hComplete/hLaunched:1;\n const severe=hrows.slice(0,3).some((x:any)=>Number(x.launched)>0 && Number(x.complete)/Number(x.launched)<0.6);\n const threeClean=hrows.length>=3 && hrows.slice(0,3).every((x:any)=>Number(x.launched)>0 && Number(x.complete)===Number(x.launched) && Number(x.failed||0)===0);\n let requestedWidth=Math.max(MIN_CONCURRENT,Math.min(QUALIFIED_CEILING,Number(supervisor.active_width||QUALIFIED_CEILING)));\n if(severe) requestedWidth=Math.max(MIN_CONCURRENT,Math.floor(requestedWidth/2));\n else if(healthRate<0.85) requestedWidth=Math.max(MIN_CONCURRENT,requestedWidth-1);\n else if(threeClean) requestedWidth=Math.min(QUALIFIED_CEILING,requestedWidth+1);\n const hb:any=await sqlite.execute(`SELECT strftime('%Y-%m-%dT%H:00Z','now') AS b`);\n const hourBucket=String(hb.rows?.[0]?.b||\"\");\n const bu:any=await sqlite.execute({sql:\"SELECT used FROM kilo_free_worker_hour_budget WHERE hour_bucket=?\",args:[hourBucket]});\n const usedBefore=Number(bu.rows?.[0]?.used||0);\n const remainingBefore=Math.max(0,MAX_CALLS_PER_HOUR-usedBefore);\n const budgetSlots=Math.floor(remainingBefore/Math.max(1,MAX_ATTEMPTS_PER_JOB));\n const activeWidth=Math.min(QUALIFIED_CEILING,requestedWidth,budgetSlots);\n const bucket=bucket15();\n const runId=\"cellpump:\"+bucket+\":\"+crypto.randomUUID().slice(0,8);\n const gate:any=await sqlite.execute({sql:`INSERT OR IGNORE INTO kilo_cell_pump_bucket_guard(bucket_id,run_id,admitted_at)\n VALUES(?,?,datetime('now'))`,args:[bucket,runId]});\n if(Number(gate.rowsAffected||0)!==1){\n return {run_id:runId,state:\"SKIPPED_BUCKET_ALREADY_ADMITTED\",bucket};\n }\n if(activeWidth<=0){\n return {run_id:runId,state:\"FREE_CALL_BUDGET_EXHAUSTED\",bucket,requested_width:requestedWidth,active_width:activeWidth,used_before:usedBefore,remaining_before:remainingBefore};\n }\n const q:any=await sqlite.execute(`\n SELECT id,kind,workstream,task_id,required_caps_json,desired_instances,priority,reason,updated_at\n FROM agent_fabric_tickets\n WHERE state='OPEN'\n AND kind IN ('PROVISION_MORE','CREATE_INDEPENDENT_USEFUL_WORK','MIGRATE_OR_REBIND_CAPABILITY','SPAWN_COMPATIBLE')\n ORDER BY priority DESC, updated_at DESC, id\n LIMIT 24`);\n const tickets:any[]=q.rows||[];\n const candidates:any[]=[];\n for(const t of tickets){\n try{const req=JSON.parse(String(t.required_caps_json??\"[]\"));if(!Array.isArray(req)) continue;}catch{continue;}\n const fp=await sha256(JSON.stringify({\n id:String(t.id),kind:String(t.kind),workstream:String(t.workstream??\"\"),\n task_id:String(t.task_id??\"\"),required_caps_json:String(t.required_caps_json??\"[]\"),\n desired_instances:Number(t.desired_instances||0),priority:Number(t.priority||0),\n reason:String(t.reason??\"\")\n }));\n const st:any=await sqlite.execute({sql:\"SELECT ticket_fingerprint,waves FROM kilo_cell_pump_ticket_state WHERE ticket_id=?\",args:[t.id]});\n const row=st.rows?.[0];\n const changed=!row || String(row.ticket_fingerprint||\"\")!==fp;\n const waves=changed?0:Number(row?.waves||0);\n t._fingerprint=fp;\n if(!changed && waves>=MAX_WAVES_PER_UNCHANGED_TICKET) continue;\n candidates.push({...t,_waves:waves,_changed:changed});\n if(candidates.length>=activeWidth) break;\n }\n\n await sqlite.execute({sql:`INSERT INTO kilo_cell_pump_runs(run_id,started_at,ticket_count,launched) VALUES(?,datetime('now'),?,0)`,args:[runId,tickets.length]});\n if(!candidates.length){\n await sqlite.execute({sql:\"UPDATE kilo_cell_pump_runs SET finished_at=datetime('now'),summary_json=? WHERE run_id=?\",args:[JSON.stringify({state:\"IDLE_NO_NEW_DECISION_RELEVANT_TICKETS\"}),runId]});\n return {run_id:runId,state:\"IDLE\",open_tickets:tickets.length};\n }\n\n const jobs:any[]=[];\n for(let i=0;i{\n const instanceId=\"kilo:\"+runId+\":\"+i;\n const caps=JSON.stringify([\"bounded_reasoning\",\"nonauthority_evidence\"]);\n const meta=JSON.stringify({schema:\"PROJECT_BRAIN_KILO_AUTOSCALE_SUPERVISOR_V1\",run_id:runId,job_id:j.id,role:j.role,authority:false,ordinary_chat_created:false,human_authority_approval:false,direct_sprites_calls:0});\n await sqlite.execute({sql:\"INSERT INTO agent_fabric_execution_heartbeats(instance_id,provider_id,brain_agent_id,workstream,capabilities_json,state,started_at,heartbeat_at,expires_at,metadata_json) VALUES(?,?,NULL,?,?,'RUNNING',datetime('now'),datetime('now'),datetime('now',? || ' seconds'),?) ON CONFLICT(instance_id) DO UPDATE SET state='RUNNING',heartbeat_at=datetime('now'),expires_at=datetime('now',? || ' seconds'),metadata_json=excluded.metadata_json\",args:[instanceId,PROVIDER_ID,j.ticket.workstream?String(j.ticket.workstream):null,caps,String(WORKER_TTL_SECONDS),meta,String(WORKER_TTL_SECONDS)]});\n try{return await runOne(\"val-cell-pump-\"+runId+\"-\"+i,j.id);}\n finally{await sqlite.execute({sql:\"UPDATE agent_fabric_execution_heartbeats SET state='ENDED',heartbeat_at=datetime('now'),expires_at=datetime('now') WHERE instance_id=? AND provider_id=?\",args:[instanceId,PROVIDER_ID]});}\n }));\n let complete=0,failed=0,usable=0,rejected=0;\n const evaluations:any[]=[];\n for(let i=0;i=3;\n let nextWidth=activeWidth;\n if(observedRate<0.60) nextWidth=Math.max(MIN_CONCURRENT,Math.floor(activeWidth/2));\n else if(observedRate<0.85) nextWidth=Math.max(MIN_CONCURRENT,activeWidth-1);\n else if(complete===jobs.length && failed===0) nextWidth=Math.min(QUALIFIED_CEILING,activeWidth+1);\n const summary={state:\"DONE\",launched:jobs.length,complete,failed,usable,rejected,\n supervisor:{qualified_ceiling:QUALIFIED_CEILING,requested_width:requestedWidth,active_width:activeWidth,next_active_width:nextWidth,health_rate_before:healthRate,budget_used_before:usedBefore,budget_remaining_before:remainingBefore,worst_case_attempts_per_job:MAX_ATTEMPTS_PER_JOB,full_width_clean_streak:fullWidthStreak,next_scale_trial_width:QUALIFIED_CEILING+1,scale_trial_ready:scaleTrialReady,scale_above_ceiling_allowed:false,authority:\"NONAUTHORITY\",ordinary_chat_created:false,human_authority_approval:false,direct_sprites_calls:0},\n jobs:jobs.map((j,i)=>({ticket_id:j.ticket.id,job_id:j.id,role:j.role,instance_id:\"kilo:\"+runId+\":\"+i,result:results[i],evaluation:evaluations[i]}))};\n await sqlite.execute({sql:\"UPDATE kilo_cell_pump_runs SET finished_at=datetime('now'),complete=?,failed=?,summary_json=? WHERE run_id=?\",args:[complete,failed,JSON.stringify(summary),runId]});\n await sqlite.execute({sql:\"UPDATE kilo_cell_pump_supervisor_state SET active_width=?,clean_full_width_streak=?,next_scale_trial_width=?,scale_trial_ready=?,last_run_id=?,updated_at=datetime('now') WHERE id='main'\",args:[nextWidth,fullWidthStreak,QUALIFIED_CEILING+1,scaleTrialReady?1:0,runId]});\n return {run_id:runId,...summary};\n}","deleted",false,"label",[47,24],"capacity","29a70aaf-cb5b-45b6-9fd3-d04be7430cbd",["D",1789174188714],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","R3A4 cohort repair isolated qualification","imageUrl","userId","6be0fc5c-1fef-4bd6-a1e1-67a3f8c0764e","pinnedFileId","01a09317-8b36-757f-b18a-5477cfa017af","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","01a0715b-703f-741f-ab35-c85020e4a5e0","tursoName","29a70aafcb5b45b69fd3d04be7430cbd","tursoHostname","29a70aafcb5b45b69fd3d04be7430cbd-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789522836959],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_100":101,"_102":103,"_58":59,"_104":105,"_106":44},"branch",{"_37":32,"_11":91,"_22":30,"_92":48,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":12,"_99":10},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mo Sadek","avatar","https://lh3.googleusercontent.com/a/ACg8ocL1eT_LHhKSg5px3nXIO6eez79aZXef466qXKh2gak-0iwrvw=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_84":-5,"_141":142,"_143":144,"_145":146,"_147":44,"_148":44,"_149":44,"_150":34,"_151":-5,"_152":-7,"_153":-7,"_154":38,"_155":44,"_156":44,"_157":-5,"_158":44,"_159":44,"_160":44,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":91,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]