^i&UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z m Z e ejZedz Zedz Zedz Zed z Zed z Zd Zd Zd ZdZdZdZd7dZd8d9dZd:dZGddZGddZ GddZ!GddZ" d; ddZ% d?dZ&d@d Z'da(d!e)d"<d#Z*d$Z+dAd%Z, dB dCd&Z-dDdEd'Z.dDdEd(Z/dDdEd)Z0dDdEd*Z1dDdEd+Z2dDdEd,Z3e.e/e0e1e2e3d-Z4 d8 dFd.Z5edf dGd/Z6Gd0d1Z7dHdId2Z8d3Z9e:d4k(r$ejvjyd56e9yy)JuQorchestrator_v2 — Factory 3D Escalado Formatos · CONTRATO FACTRY 2026-05-09 ============================================================================ Wire actualizado al contrato cristalizado en chat Fer 2026-05-09 (msgs 4684–4701): 1. CAJA ÚNICA MUTABLE — un solo `caja.json` por flow que viaja de estación en estación. Cada estación lee la caja entera, escribe SU sección. NO archivos sueltos `_analysis.json`, `_strategy.json`, etc. 2. SUPERVISOR BLOQUEA + RETROLOOP — tras cada estación, supervisor (L1+L2, escalando a L3 en flag) audita lo escrito en la caja. Si BREAK → re-spawn ejecutor con feedback inline. max_retries=5 default. 3. SHARED_STATE.JSON BUSCAR×4 — los 4 buscadores en paralelo coordinan antes de cada query: leen `_buscar_shared_state.json`, evitan duplicar queries/video_ids, escriben sus claims antes de avanzar. 4. DRY MODE (--dry-run) — smoke test sin LLM/network/Trello reales. Ejecutores generan fixtures plausibles, supervisor siempre APPROVE. Modo de uso: # Smoke test interno (sin red, sin LLM, sin Trello): python orchestrator_v2.py --dry-run --from-inbox _flow_inbox/.json --once # Run real (cuando los stubs estén conectados a subagentes/skills): python orchestrator_v2.py --from-inbox _flow_inbox/.json REGLAS DURAS HARDWIRED: - 1 agente = 1 skill (factory_metadata.json es la fuente de verdad) - Supervisor BLOQUEA · max_retries=5 · sin atajos - Caja única mutable · append/merge por sección · NUNCA dispersar - Default Opus en cualquier llamada LLM (msg 4658) ) annotationsN)Path)datetimetimezonezfactory_metadata.json _flow_inbox_runsz_task_state.jsonz_orchestrator_stop.flagz.8345671365:AAFNAmnzIBleXEOMvMOiYFUR6xkLU_Mehf8 6002482241cdtjtjj SN)rnowrutc isoformat@C:\Users\ferna\proyecto cero\_factory_3d_demo\orchestrator_v2.pynow_isorAs << % / / 11rcBttjdzS)N)inttimerrrnow_msrDs tyy{T! ""rcZtjdd|jd}|xsdS)Nz[^a-zA-Z0-9_-]+_flow)resubstrip)ss rslugifyr!Gs* !3*005A ;rct|jdd}|jdtjddjdd}|d|}| |j}t|S)Nproductunknown timestamp:-.r)r!getrreplacestem) inbox_payload inbox_pathr#tsbases rderive_flow_idr0Ksqm'' 9=>G   ; 2 : :3 D L LSRU VBYat D 4=rcTtjtjdSNutf-8encoding)jsonloads META_PATH read_textrrr load_metar:Ss ::i))7); <>*b1<<$ 8 !& Hd+&!)5 1 W_(D)j.E& % !HSM y"%,,)tzz(,,s*;%PQ .   3rc|jjr$|jjjSdS)Nr)rGrIstatst_sizerQs r size_byteszCaja.size_bytess-+/99+;+;+=tyy~~''D1DrN)rAstrrFrrLrmreturnrm)r\rm)r`rwryz dict | None)r*r$)r`rwrprmrhrwrfrw)ryr) __name__ __module__ __qualname____doc__rNrRrJr^rarrrvrrrr<r<Zs+O  A^08Err<c8eZdZdZddZd dZd dZd dZd dZy) SharedStateuJSON compartido entre los N agentes paralelos del cluster. Patrón equivalente a `buscador-paralelo-fb-gethookd._buscar/shared_state.json`.c ||_|jjsj|jjjdd|jj t j tggggiddddyy) NTr>)rBqueries_in_progress queries_donevideo_ids_already_evaluatedcandidates_found_so_farclaimsFr rVr3r4)rGrIparentrHrZr6r[r)rKrGs rrNzSharedState.__init__s yy! II   " "4$ " ? II %i') "/1+- -"!"-8? ! @"rc`tj|jjdSr2rPrQs rrRzSharedState._loadrSrcj|jjtj|dddyrUrY)rKds rrJzSharedState._saves' TZZaHSZ[rc|j}||dvs||dvry|dj||dj|gj|td|j |y)zIReturns True si pudo tomar la query, False si ya estaba en progreso/done.rrFr)qr.T)rRrcrjrrJ)rKagent_idqueryrs r take_queryzSharedState.take_querysr JJL A+, ,>9J0J  ''. ( x,33%wy4QR 1 rc |j}||dvr|dj|||dvr|dj||D]}||dvs |dj| |dj||j |y)Nrrrr)rRremovercextendrJ)rKrr video_ids candidatesrvids r finish_queryzSharedState.finish_querys JJL A+, , # $ + +E 2 .) ) n  $ $U +C!9::/077< #$++J7 1 rN)rGrrx)rrm)rrwrrwrybool)rrwrrwr list[str]rz list[dict]) rzr{r|r}rNrRrJrrrrrrrs$X @A\ rrc4eZdZdZdddddddZd d d Zdd Zy ) SupervisoruRWrapper L1 (verifier determinista) + L2 (Haiku olfato) + L3 escalación Opus. Cada supervisor lleva su PDF sub-proceso como audit base canónica (`_pdfs/PDF_.pdf` · msg 4717+4723 Fer 2026-05-09). El PDF define literalmente qué validar — supervisor NO inventa criterios. En DRY mode: L1 valida que la sección exista y no esté vacía + PDF presente → APPROVE. En modo real: L1 ejecuta verifier_l1 declarado en metadata; L2 invoca Haiku con el PDF como contexto; L3 escala a Opus si L2 levanta flag o L1 falla, también con el PDF como contexto. zPDF_DESCARGAR.pdfzPDF_ANALIZAR.pdfzPDF_INTERPRETAR.pdfzPDF_BUSCAR.pdfzPDF_COMPARADOR.pdfzPDF_TRELLO_EDITOR.pdf descargaranalizar interpretarbuscar comparador trello_editorc||_||_|jdijdd|_|d|_|j j|j}|rt dz |z |_yd|_y)N supervisorid sup_unknown_pdfs) station_defdry_runr) supervisor_id station_id PDF_NAME_MAPROOTpdf_audit_base)rKrrpdf_names rrNzSupervisor.__init__sq& (__\2>BB4W%d+$$((9=Etg~84rc|j|j}|dd|jdfSt|tr|sdd|jdfSt|tr t |dk(rdd|jdfS|j r+|j jsdd|j fS|jr.|j rd |j jnd }d d |fSy )uNDevuelve (verdict, reason). verdict ∈ {APPROVE, BREAK_}BREAK_EMPTY_SECTIONzcaja.sections.z no existez es {}rz es []BREAK_PDF_BASE_MISSINGu"PDF base de auditoría no existe: u · base PDF: APPROVE dry_run_pass)rreal_pass_stub) rarrkrmrlrorrIrname)rKcajargr/s rauditzSupervisor.audits##DOO4 ?)^DOO;LJ+WX X gt $W)^DOO;LH+UV V gt $W):)^DOO;LF+ST T   t':':'A'A'C,0RSWSfSfRg.hi i <[]DdV45 5 -rN)F)rrmrr)rr<ryztuple[str, str])rzr{r|r}rrNrrrrrrs- )&,"*0 LP-rrceZdZdZddZdZy) HypothesisuUna hipótesis raíz para resolver un fallo. Lleva una idea humana + el feedback que se inyecta al ejecutor en el siguiente intento.c<||_||_||_||_yr rlevelideafeedback)rKid_rrrs rrNzHypothesis.__init__s    rc`|j|j|j|jdS)NrrrQs rto_dictzHypothesis.to_dicts$gg DIISWS`S`aarN)rrwrrwrrwrrw)rzr{r|r}rNrrrrrrsD! brrc 4 tjdddddd|gdd|d }|jd k7ry tj|j }|j d ry |j d dj}|jdr5tjdd|tjj}tj|}|j dxsg} t| dk7ry g} t| dD]t\} } | j dxsdj} | j dxsdj}| r|sy | jt|d| || |v| S#t $rYy wxYw)uLlama a `claude --print --model opus --output-format json` con el prompt y parsea 3 hipótesis. Devuelve None si algo falla (caller hará fallback). Patrón: el outer JSON tiene `result` con el inner JSON string a parsear.claude--print--modelopus--output-formatr6Tr3)capture_outputtexttimeoutr5rNis_errorresultr```^```(?:json)?\s*|\s*```$flags hypotheses)startrrrrr) subprocessrun returncoder6r7stdoutr)r startswithrr MULTILINEro enumeratercr Exception)promptrrexpected_ids_prefix timeout_sprocouter inner_textinner hyps_dataoutihrrs r_invoke_opus_for_hypothesesrsz ~~ y)V5FPV WdI  ??a  4;;' 99Z YYx,224   ' ;RSUS_S_`ffhJ :&IIl+1r y>Q iq1DAqEE&M'R..0Dj)/R668Hx JJz&'q,e$  2 s*0F 0F $BF A F $&F FFc |d}|rYtd|ddd|dd|d|d  td|d dd |d d|d|d td|ddd|dd|d|d gStjj|d}|r tdz |z nd}d}|r'|j r |j dddd}tj|jjdiddd}d |jd!|d"|d#|d$|d% } t| |dd|&} | t|||d'(S| S#t$rd}YwxYw))u@QC de la estación → 3 hipótesis RAÍZ distintas entre sí. Distintas en el sentido de raíz causal, no rephrasings. DRY mode → 3 stubs canónicos. REAL mode → invoca Opus headless (claude --print) con prompt sólido; si falla parse o CLI, fallback a los stubs canónicos para no bloquear el flow.rqc__1qcu[QC raíz 1] PARÁMETROS — z con valores demasiado agresivosu [RESCUE QC-H1 · u] El intento estándar falló: u. Hipótesis raíz 1 (PARÁMETROS): los parámetros usados son demasiado agresivos. Reintenta con valores conservadores y timeout x2 sobre el default. NO cambies de herramienta, NO cambies de input — solo afloja parámetros.r_2u5[QC raíz 2] HERRAMIENTA — la herramienta usada en z no aplica al casou [RESCUE QC-H2 · u. Hipótesis raíz 2 (HERRAMIENTA): la herramienta primaria no aplica a este caso concreto. Cambia a la alternativa documentada en el PDF de la estación (segundo método declarado). NO toques parámetros — solo cambia de método._3u+[QC raíz 3] INPUT — el input que recibe u está mal formateadou [RESCUE QC-H3 · u. Hipótesis raíz 3 (INPUT): el input que recibe la estación viene mal formateado / con caracteres raros / encoding inconsistente. Normaliza/valida input (strip, ASCII safe, schema check) ANTES de invocar la herramienta. Mismo método y parámetros que el intento estándar.rrNr3ignore)r5errorsprDFreuEres el QC de la estación uG de la factoría escalado_formatos. El sub-agente ejecutor falló con: ul Genera 3 HIPÓTESIS RAÍZ distintas entre sí (NO 3 rephrasings de la misma idea, tres causas raíz CAUSALMENTE distintas — p.ej. una sobre PARÁMETROS, otra sobre HERRAMIENTA/MÉTODO, otra sobre INPUT/DATOS), cada una con un fix concreto que el ejecutor de la estación pueda aplicar literalmente en el siguiente intento. No inventes pasos fuera del scope de u). PDF base de la estación (recortado): z Caja del flow (recortada): u1 Devuelve SOLO un JSON con esta forma exacta, sin texto adicional, sin ```: {"hypotheses":[{"idea":"","feedback":""},{"idea":"...","feedback":"..."},{"idea":"...","feedback":"..."}]}rTr)rrrr)rrIr9rr6r[r^upperrqc_generate_3_hypotheses) rr initial_breakrsidrpdf_path pdf_excerpt caja_excerptrhypss rrrCs d C cU" t4SE9YZ/u4STaSbchh j cU" tLSEQcd/u4STaSbcNN P cU" tB3%G\]/u4STaSbcRR T  0&&**33H,4tg~($HKHOO% ",,gh,OPUQUVK::dnn.22:rBQVWX]Y]^L %ciik]3..;_=0 14u522=?''3n5Q R  'vsDPSTWSXk ZD |' T=RVWW K- K s&D99 EEc |d}|r\td|ddd|dd|d|d |d  td|d dd |dd|d|d td|ddd|dd|d|d gSdjd|D}tj|j ddd}d|j d|d|d|d }t ||dd|!} | t||||d"#S| S)$uMASTER QC central → 3 hipótesis NUEVAS, distintas de las 3 que QC ya probó. El master ve el flow entero (caja completa), no solo la estación.rmaster_rmasteru5[MASTER raíz 1] CROSS-FLOW — el fallo no está en z, viene de aguas arribau [RESCUE MASTER-H1 · u/] Las 3 hipótesis QC fallaron. Break inicial: u. Hipótesis cross-flow 1: el problema NO es de esta estación, viene de una estación previa que dejó datos malos en la caja. Lee caja.sections completa, identifica qué sección previa parece corrupta, y rehaz uQ usando un input reconstruido a partir de input_start (no de la sección previa).rru,[MASTER raíz 2] FALLBACK GLOBAL — saltar z con modo degradadou [RESCUE MASTER-H2 · u. Hipótesis cross-flow 2: usa el FALLBACK a nivel flow para esta estación. Genera el output mínimo viable de la sección (cache previo, mock canónico, valores por defecto razonables) marcado con flag degraded_mode=True para que estaciones siguientes lo sepan, y sigue.ru/[MASTER raíz 3] CONTRATO — el supervisor de z aplica criterios incorrectosu [RESCUE MASTER-H3 · u. Hipótesis cross-flow 3: el contrato del supervisor de la estación está roto vs la realidad del input concreto. Re-lee el PDF base de la estación y la sección de la caja, decide si el output actual realmente cumple el espíritu del PDF, y si sí, marca la sección con override_supervisor_reason="" para que el supervisor apruebe. c 3VK|]!}d|ddd|ddd|ddd#yw) z - QC hypothesisrz (FAIL): r → detailNr.0as r z/master_generate_3_hypotheses..sPA !L/$'( !L/&2I1J%PQRZP[\`]`PaObcs')FreN'uEres el MASTER QC central de la factoría escalado_formatos. Ves el flow ENTERO, no solo la estación que falla. La estación que falla es z. Break inicial: uM El QC de la estación ya probó estas 3 hipótesis raíz y TODAS fallaron: u Genera OTRAS 3 hipótesis distintas entre sí Y distintas de las 3 que ya probó QC. Tu nivel es CROSS-FLOW: piensa en (a) el problema viene de aguas arriba (otra estación dejó datos malos en la caja), (b) usar fallback global / modo degradado, (c) el contrato del supervisor está mal calibrado contra este input concreto, (d) re-arquitectura puntual. Cada hipótesis con fix concreto aplicable. Caja completa del flow (recortada): z Devuelve SOLO JSON, sin texto, sin ```: {"hypotheses":[{"idea":"...","feedback":"..."},{"idea":"...","feedback":"..."},{"idea":"...","feedback":"..."}]}rTr)rjoinr6r[r^rrmaster_generate_3_hypotheses) rrr qc_attemptsrr qc_summary caja_fullrrs rr r s d C #b!8LSEQhi3C59,,9?;r!E!r t v #b!8CC5H[\3C59,,9?;rr t #b!8FseKhi3C59,,9?;qq s#  6J 4>>+%@%HI EEHYY[MR')WWaVbc0 1:{;Q R  'vsHT[\_[`Ra bD |+K}kcghh Krc *|d}|j}djd|D}djd|D} d|jd|d|dd d |d | d |jd } |jd|dz } | j | d|ry ddlm} ddl m } | jt| ddjd}| jdtd|ddi}| j!|d5}d |j"cxkxrdknccdddS#t $rYwxYw#1swYyxYw#t $rH} |jd|dz j t%|dn#t $rYnwxYwYd}~yd}~wwxYw) uPing SOS a Fer cuando QC+MASTER agotaron las 6 hipótesis sin solución. DRY mode: deja un marker file _telegram_SOS_.txt en run_dir (no llama API). REAL mode: POST a Telegram Bot API.rrc 3PK|]}d|ddd|dd|ddd yw) z QC rrrr · rNxrrs rr z%telegram_alert_fer..sCZeUV%,%&eAhK=Qx[#=N.sC^mYZ)AlOD)*%( }D8TcAR@ST^mru!🚨 SOS factory_v4 · estación z bloqueada flow_id: z break inicial: Nu. QC probó 3 hipótesis raíz · todas FAIL: u2 MASTER probó otras 3 hipótesis · todas FAIL: z caja: z" Necesito tu ayuda para destrabar._telegram_SOS_z.txtr3r4Trtrue)chat_idrdisable_web_page_previewzhttps://api.telegram.org/botz /sendMessagez Content-Typez!application/x-www-form-urlencoded)dataheaders r,z .error.txtF)rAr rrGrFrZrurllib.requestrequest urllib.parseparse urlencodeTELEGRAM_CHAT_FERencodeRequestTELEGRAM_TOKEN_SOSurlopenstatusrw)rrrrmaster_attemptsrrrA summary_qcsummary_masterrmarker_ur_upbodyreqres rtelegram_alert_ferr6s d CllGZeJYY^mN ,CIIK=99'-./88B|D<l K#%HI  [[b[ )Q!(((S(* )%    $* )   \\nSE< < H HQZa H b    sgD&A%ED5 E& D21D25D>:E>E F -E98F 9 FF FF  Fc|syd|dS)Nru% [RETRY] Supervisor previo rechazó: u. Corrige específicamente eso.r)supervisor_breaks r_retry_feedback_textr9s  34D3EEd eer'TaskStateBridge | None'_GLOBAL_BRIDGEc|ayr r;)bs r_set_global_bridger?sNrctSr r=rrr_bridgerAs rct}| |j||ytd|j d|y#t$rY+wxYw)zHEscupe un log al HTML en vivo si hay bridge montado, sin bloquear si no.N[] )rA append_logrprintr)rrr>s r_emitrG sU A}  LL %  Aekkm_Btf %&   sA A  A c z td|d|d|d|d} tjdddd d d d d |g tjtjdddd}d}d}|j D]@}|j } | s tj| } | jdd} | dk(rs| jdi} | jdgD]I} | jddk(r}| jdd}tj| jdid}td|d|tdt|d D]}td|d!|||d z| jdd"k(s| jd"dj }|s|}|jd#D]g}|j }|st|d krtd|d$|6tdt|d D]}td|d$|||d ziL| d%k(r| jdi} | jdgD]} | jdd&k(s| jdd}t|t rd#j#d'|D}t%|}|jd#D]g}|j }|st|d krtd|d(|6tdt|d D]}td|d(|||d zi| d)k(s| jd)dj }|j'd*r5t)j*d+d|t(j,,j } tj|}C|j3}|?|r=t)j.d-|}|r% tj|j1d}|dk7rddd.|fS|y/d|dfS#t$rYwxYw#t$rQt)j.d-|}|r5 tj|j1d}n#t$rYnwxYwYwxYw#t$rYwxYw#t$r}ddd0t%|dd1fcYd}~Sd}~wwxYw)2u(Spawnea el subagente canónico vía `claude --print --model opus` con stream-json. Cada evento del subagente (tool_use, text) se escupe al bridge en vivo. Devuelve (ok, parsed_result_dict, error_msg). El subagente debe terminar devolviendo en su mensaje final un JSON que parsearemos.infou# · spawneando subagente canónico zUse the z agent to perform this task. u CRITICAL: cuando el subagente termine, devuelve en tu mensaje final UN ÚNICO JSON sin texto adicional, sin ``` blocks, en una sola línea, con todos los campos pedidos.rrrrrz stream-jsonz --verbosez--include-partial-messagesTr3r*r)rstderrrr5rbufsizerNtype assistantmessagecontenttool_userinputFreu · 🔧 rru · rrruser tool_resultc3bK|]'}t|ts|jdd)yw)rrN)rkrmr))rxs rr z)_spawn_canonical_agent..Zs'+bs!jYZ\`NaAEE&",=ss//u · ↩ rrrr\{[\s\S]*\}\s*$z claude exit=)FNu%subagente no devolvió JSON parseablezspawn exception: )rGrPopenPIPESTDOUTrrr6r7rr)r[rangerosplitrkrlr rwrrrrsearchgroupwait)canonical_namerrr full_promptr last_text result_objrawlineevtmsgctnametinputrrlnrout_srmrcr5s r_spawn_canonical_agentrps  &ZL CNCSTU >""B6(Ka b a? y)V   )    ??:+<+< 1   ;;C99;D ZZ%vr"AKffY+B/AuuV} 2 !fb 1!%AEE'2,>U!Sf(8 %&IJ!&q#f+s!;A!&^,$)&^4DD2M$N-21c"gs-C(-f8HRPQRSTWRW[M6Z([.D'70,fffY+B/AuuV} 5eeIr2%c40"&))+bs+b"bC #C"'++d"3B!#B#% ("2w#~ %f0@.M N).q#b'3)?A$)&^4DHRPQRSTWRW[M2Z$[*@#4 0hx,224##E*FF#>EQSQ]Q]^ddfE !!%E!2JwHYY[  ) ,i8A!%AGGAJ!7J 7$,rd 33 3  GZ##W  l!! "4e>>?sA(RPC%R"R#CR'C R2A&RP'./R$R RRR P$ R#P$$R'!R $Q.-R. Q:7R9Q::R=RRR R RRR R:R5/R:5R:c |jjdi}|jdxs|jd}|jdd}t|jz }|j dd|dz }|s t d d y |j ru|jjd kDrX|jjd z} t dd| d|jddt|| |ddddd| dfS|r;t dd||jdd|t|dzd|xsddddy|rd|nd } d!|d"|d#|d$| } td| dd%&\} } }| sd'|fS| jd(}|rt|j sd'd)|fS| jd*xs&t|jjd z} t dd+| d,| jd-|jdd't|| || jd-|xsdd.dddd/| d0| jd-fS)1u6Estación DESCARGAR: spawnea el subagente canónico descargador-video-escalado. El subagente decide qué herramienta usar (yt-dlp / Playwright MCP / servicio web FB downloader / inspect DOM) según funcione. Si recibe retry_feedback de la rescue ladder, el subagente lo aplica cambiando de método.rC video_urlurlr#r$Tr>z video.mp4erroru=descargador-video-escalado · no hay video_url en input_start)F no_video_urliisuccessu+descargador-video-escalado · cache hit · z KBr) cache_hit video_pathsize_kbrsr*zdescargador-video-escaladorhrfz cache_hit (zKB)rIuOdescargador-video-escalado · [DRY] spawnearía subagente canónico para bajar z.FAKEiN)rrsrxryretry_feedback_appliedTzDRY OKuI RETRY FEEDBACK (aplica este cambio si la herramienta anterior falló): rzDTarea: descargar el video Facebook de esta URL al disco local. URL: z Producto: z Ruta de salida exacta: uD Métodos disponibles en cascada (usar el primero que funcione, fallback al siguiente si falla): 1) yt-dlp con cookies-from-browser chrome 2) MCP playwright: navegar a un servicio web FB downloader (ej. fdown.net, getfvid.com), pegar la URL, descargar el mp4 resultante con browser_evaluate o request directo 3) MCP playwright: navegar a la URL FB original, inspeccionar DOM/network requests para extraer media_url firmado Cuando termines, devuelve JSON: {"video_path":"","size_kb":N,"method_used":"","duration_s":N}XrFrxu*subagente devolvió video_path no existe: ryu+descargador-video-escalado · mp4 listo · u KB · método: method_used)rwrxryrsrr{z downloaded zKB via ) r^r)RUNS_DIRrArHrGrIrtrurrrwrpr)rrrretry_feedbackinprsr#out_dirout_pathry feedback_noterokrerrrxs r run_descargarrs ..   }b 1C ''+  0#''%.Cggi+G%G MM$M.$H  gVW$X]]_44w>--/))T1 iFwisST ;S]wWZ) !=  ?{7)3/// fghkglmn ;Cs8}w7N[_&4&<) !=  ?xFbcqbrsLNM uI""*,c /  --I6S^jmnOB czL)J T*-446B:,OOOjj#PZ(8(=(=(?(G(G4(OG )B7)K[\b\f\fgt\u[vwx{#j/g6::m#<"0"8D% 9 ; ;wiwvzz-/H.IJ JJrc |jdxsi}|jd}|sy|jjdi}|jddjddd d }td z |z d z }|r.t d d|j ddddddd|xsd dddy|rd|nd} d|d|d|jd d!d"|d#| } td| dd$%\} } } | sd| fSt d&d'| jd(|j di| ||xsd d)dddd*| jd+d,d-fS).uEstación ANALIZAR: spawnea analizador-combo-completo. El subagente decide cache lookup, faster-whisper, frame extraction y síntesis combo.rrx)Fzno_video_path en caja.descargarrCr#r$ rN _productosz_analysis.jsonrIuManalizador-combo-completo · [DRY] spawnearía subagente para análisis comborTFuDRY · sin trabajo real*g>@es)rrw transcript word_countduration_secondslanguage_detectedr{r*zanalizador-combo-completorzr| RETRY FEEDBACK: ru7Tarea: análisis combo completo del video. video_path: z producto: u país: countryESz cache_path: u? Sigue el procedimiento del subagente: PASO 1 cache lookup → si miss, PASO 2 faster-whisper transcripción + ffmpeg frames + síntesis combo (awareness, sof, jergas, deseo, avatar, etc). Cuando termines, devuelve JSON: {"cache_hit":bool,"transcript":"...","duration_seconds":N,"language_detected":"es","combo":{...}}r~rvu7analizador-combo-completo · análisis OK · cache_hit=rw)rxr{u analizado · r?r )rar)r^r*rrGrrrp)rrrrdescrxrr# cache_pathrrrrrs r run_analizarrs   [ ) /RD,'J 7 ..   }b 1Cggi+33C=crBG $w.1AAJ fef :%?X$T&4&<( !<  > @N+N+;s!C DAF FFrc |jdxsi}|jjdi}|rBtdd|j ddddd gd d d i|jd d|xsddddy|rd|nd}t j |ddd}t|jd d}d|jddd|jddd|d|d | } td| dd!"\} } } | sd| fStd#d$| jd%d&| jd'|j di| d(|xsdidddd)| jd%fS)*uEstación INTERPRETAR: spawnea interpretador-estrategia-busqueda. El subagente arma la estrategia de búsqueda a partir del combo del análisis.rrCrIu@interpretador-estrategia-busqueda · [DRY] spawnearía subagenterT product_awarejerga_az dormir mejoredadz40-55 saturatedFN)r awareness sofisticacionjergasdeseo_principalavatarneed_complex_videosr{r*z!interpretador-estrategia-busquedarzr|rrrei@ueTarea: interpretar el análisis del video y producir la estrategia de búsqueda. INPUT: producto: r# país: rrz saturated: uE ANÁLISIS PREVIO (transcript del video ganador + combo extraído): un REGLAS DURAS (Fer 2026-05-09 voice msgs + REGLAS CLAUDE.md): R1) AWARENESS = UN SOLO VALOR canónico Schwartz (NO descripciones tipo "Problem→Solution"). Valores válidos exactos: "unaware" | "problem_aware" | "solution_aware" | "product_aware" | "most_aware". DECIDIR el awareness PRINCIPALMENTE de los PRIMEROS 15 SEGUNDOS del transcript (≈37 palabras). El resto del video puede mostrar reframes pero el AWARENESS DOMINANTE para targeting es el de la apertura. R2) DESEO_PRINCIPAL = UN ÚNICO DOLOR aislado (REGLA aislar-un-dolor-por-creativo msg4467). NO mezclar dolores compuestos tipo "dolor de cabeza Y dolor en la nuca". Si el video ataca cefalea matutina, el deseo es "despertarse sin cefalea matutina/dolor de cabeza al despertar" punto. NO añadir cervical/nuca/postural. REGLA #150: deseo emocional ≠ nombre producto (almohada cervical → deseo es CEFALEA, no "dolor cervical"). El deseo es el dolor que la apertura del video activa. R3) JERGAS deben incluir al menos 1 MASS EDUCATION explícitamente marcada (REGLA #112): palabra/frase que el avatar mismo usa cotidianamente para nombrar su problema (ej. "cefalea matutina", "dolor de cabeza al despertar", "los años no perdonan", "cervicales"). Marca la mass education con campo aparte. R4) NADA de awareness_secondary. UN solo awareness. R5) TEMPORALIDAD: cómo de urgente/crónico es el dolor (diaria/semanal/estacional/etapa-vida). R6) Si saturated=true: marca need_complex_videos=true → buscar videos LARGOS VSL/storytelling (>30s) porque la audiencia tiene el problema pero NO está dispuesta a comprar todavía, hay que agitar+educar. Si saturated=false: videos cortos talking-head normales OK. Devuelve SOLO JSON sin texto adicional ni ```: {"awareness":"","awareness_evidence_first_15s":"","sofisticacion":<1-5>,"jergas":["..."],"jerga_mass_education":"","deseo_principal":"","deseo_evidencia_video":"","avatar":{"edad":"...","genero":"...","contexto":"...","profesion":"..."},"temporalidad":"","fuerza_cambio":"...","antagonistas":["..."],"formato_referente":"...","duracion_referente_seg":,"need_complex_videos":,"match_criteria":{"awareness":"","deseo_keywords":["..."],"jergas_obligatorias":["..."],"sof_min":,"sof_max":,"duracion_min_seg":},"queries":["query 1 producto exacto España","query 2 producto exacto UK","query 3 deseo cefalea matutina ES","..."]}r r~rvu/interpretador-estrategia-busqueda · awareness=rz sof=rr{z awareness=) rar^r)rGrrr6r[rrp) rrrrrrranalisis_summaryrrrrrs rrun_interpretarrs  ,2H ..   }b 1C fXY =/A knw' UZ@[&4&< + !D  F @N+N+;Ka]a&b&.QS :fjj567 77rc t|jz dz }t|}gd}|rtddg}|D]}d|d} |j || } | sd|d} |j || td|d| d t d D cgc] } d |d |  } } | D cgc]} || d d }} |j || | |td|dt|d|j||jddt||t||dd|xsddddddt|dfS|jdxsi}tj|ddd}|jjd i}|rd!|nd"}t!|jd#d}i}d$D]\}}d%|vrd&nd'}d(|d)|jd*d"d+|jd,d-d.|d/|d0|d1|d2|d3|d4|}|d5}td|d6|d7t#j$d8d9d:d;dd?||<g}|j+D]\}} |j-d@A\}}|rtj.|ni}|jdBd"j1}|j3dCr5t5j6dDd"|t4j8Ej1}t5j:dF|}|r$tj.|j=dGni}|jdHg} td|dIt| dJ|j| |jd|t||t||xsddNddddOt|dPfScc} wcc} w#t>$r(}!tdK|dLt|!ddMYd}!~!d}!~!wwxYw)QuGCluster paralelo de 4 buscadores · coordinados vía shared_state.json.z_buscar_shared_state.json) buscador-fb-1 buscador-fb-2buscador-gethookd-1buscador-gethookd-2rIuKbuscar · arrancando 4 sub-agentes en paralelo (factory_metadata declara 4) fake_query__v1_v2u · query "u'" tomada del shared_state · ejecutandor vid_rg333333?)rvideo_id match_scorervrz candidatos encontrados (DRY)rTNr)rshared_state_path agents_runcandidates_totalcandidates_sampler{r* buscadores_x4rzu DRY OK · u& candidatos · shared_state coordinadorFrerrCrrr))rfb_1)rfb_2)rgh_1)rgh_2fbz-FB Ads Library (Apify + meta_ads_library_api)zGetHookd (gethookd.ai)zWCONFIRMO_LECTURA_AGENTE_CANONICOS Use the buscador-paralelo-fb-gethookd agent with id=u%. TAREA: buscar candidatos REALES escalados que coincidan con el combo ganador en awareness + deseo principal + temporalidad + jerga mass education. NO buscar genérico, NO buscar por categoría producto (ej. "almohada cervical"), buscar por el DESEO concreto del avatar. INPUT: producto: r#u país DESTINO: rrz' (donde lanzaremos el ad) saturated: z fuente asignada: z shared_state_path: ur (coordina con los otros 3 paralelos · NO duplicar queries/video_ids) STRATEGY (interpretar combo del ganador): u REGLAS DURAS canónicas (REGLA #141 + #91 + #30 + #112): R1) PAÍSES ORIGEN ESTRICTO: UK / USA / Australia. ES/PT/BR/India NO son origen válido. Cascada países: UK → USA → Australia. Si en UK no hay → USA → AU. NO incluir ES/PT/otros. R2) SCALED_DAYS sweet spot ESTRICTO 30-100 días (REGLA #141). <30d=raw sin validar, >100d=quemado/copiado. Ambos extremos DESCARTAR. R3) Cascada REGLA #46: producto EXACTO (almohada cervical igual) → producto SIMILAR (otra almohada o soporte cervical) → NICHO (productos cefalea matutina o dolor cabeza al despertar) → MACRO (productos COD dolor crónico avatar 35-60). NO saltar niveles. Documentar nivel cascada usado por candidato. R4) Awareness MATCH ESTRICTO: candidato.awareness == match_criteria.awareness (mismo valor canónico Schwartz, NO secundarios). R5) DESEO MATCH: candidato debe atacar el MISMO dolor aislado del ganador. Si ganador=CEFALEA, descartar candidatos que sean solo cervical/postural/mareos. REGLA aislar-un-dolor. R6) MASS EDUCATION REGLA #112: candidato debe mencionar al menos 1 jerga obligatoria en sus primeros 15 segundos del speech. R7) SATURACIÓN: si saturated=true O awareness=problem_aware/solution_aware con sof≥4 (catálogo público) → preferir videos LARGOS VSL/storytelling >30s para agitar+educar. Default mercado España COD productos saturados = VSL largo. R8) REGLA #30 sof 4: hooks tipo "el original / no es el típico / este sí sirve" → OK. Hooks tipo "acabo de descubrir / conoces este invento / nuevo en el mercado" → DESCARTAR (sof 1-2). R9) Devolver mínimo 2 candidatos válidos por buscador. Si no encuentras → expandir cascada países (UK→USA→AU) y nivel (exacto→similar→nicho→macro). Si tras cascada completa no hay 2 candidatos → flag insufficient + explicar qué descartaste y por qué. Cada candidato debe traer: video_id, url, fuente, advertiser, country (UK/USA/AU), scaled_days (30-100), length_seconds, awareness, deseo_principal_detectado (cita primeros 15s), sofisticacion, jergas_detectadas, mass_education_match, formato, hook_apertura, cascada_nivel (exacto/similar/nicho/macro), match_score (0-1). Devuelve SOLO JSON sin texto ni ```: {"agent_id":"z ","fuente":"z","candidates":[...]}uI CRITICAL: termina devolviendo UN ÚNICO JSON sin texto adicional ni ```u. · spawneando buscador-paralelo-fb-gethookd ()rrrrrr6r3)rrJrr5rrrrrrrrVrru · devolvió candidatoswarnu · falló: r)rrrrr{u buscar · z! candidatos totales (4 paralelos)) rrArrGrr[rrorrrrwrar6r[r^r)rrrXrYrZitems communicater7rrrrrr]r^r)"rrrrrssagentsall_candidatesrrtookjrrrinterpstrategy_summaryrrrprocs search_idfuenterraprrrrrnrcandsr5s" r run_buscarr6s 4<</2MM & 'B ]F fcdHhZs+A==1-D!(3/ h* &XJk!4[\ ]8=aA14z1#.IAbklbk[^xSQUVbkJl OOHaJ ? )zc*o->>[\ ]  ! !* - 8!$%6!7 #N 3!/!3&4&< &   2z#n"5!66\]]]  } - 3Fzz&u=etD ..   }b 1C@N+N+;,"awareness_target":""}r}r~rawareness_targetrrrvucomparador-finalistas · z finalistas mismo awareness=""insufficient_candidates)rcountrrr{z finalistas (mismo awareness r) rar)rGrorrr[r6r[rp)rrrrrrrrrrrrrrrs rrun_comparadorrsC   x ( .BFL)RVZZ8K-LRPRJ   } - 3F fEc*oEVVabc f[\ <inopiqriqdeaSzq1u)R^_iqr q&4&< * !8  : 0 A@N+N+;A^ wwy,-.GGId+,-ll^$AAQ@RS11=?SSaRbc++7.9$$(JJvE$J5D$Q#RS 95A%4HIJ )k*`(ao_opwxHwIIL /k5  p--KVUdpstOB cz )FvzzR]G^F_`a) )*N,Bd) ;= ?6::k#:";< <` con el dossier completo de qué se probó (para el master/forense).rFzno executor para rrz supervisor-rragent/agentec ^ |\}}|s1tdd d|dddtd dddd|fStd d d d  j\}}|d k(rtd dd|ddd|fStd dd|d|ddd|d|fS)Nrru: «Jefe, fallé. r»u2: «Recibido. Pasamos a hipótesis alternativas.»Fu EXEC_FAIL · rIu: «Hola jefe, ya terminé u. ¿Está bien? Mira el log.»rrvu: «Revisado. Todo OK (u!). Aprobado, pasa al siguiente.»TuEXEC_OK · SUP_OK · u: «No me cuadra: ru. Tienes que corregir.»u SUP_BREAK · )rGr) rrexec_msgverdictreason agent_labelrrexecutorrrsup_idrs r_attemptz(run_with_rescue_ladder.._attemptksk7NK H &[Mvh6HRVSVHXXZ[ \ &VHE+6hi jM(44 4 f U6(2McURpqr$**40 i  )xu[M9PQWPXXyz {099 9 fk]2DWITRXQYYqrs gYd6(;;;rrTustd · ru⚠ u estándar FAIL · u' · escalando a QC (3 hipótesis raíz)rIu🧪 QC rPASSFAIL)rrr_rescue_r)level_resolvedwinning_hypothesisrrr, fer_pingedr.r*z rescue-ladderrzrvu✓ QC u PASS · ru✗ QC FAIL · u5 las 3 QC fallaron · escalando a MASTER (QC central)u 🧪 MASTER ru ✓ MASTER ru ✗ MASTER rt❌ u9 3+3 hipótesis FAIL · pidiendo ayuda a Fer por TelegramNu&rescue_ladder_exhausted · fer_pinged=)rrwrytuple[bool, str]) EXECUTORSr)rr rErrrrrcrrrrr r6r)rrrbridger  agent_namesrrrhrqc_hypsrr master_hypsr,pingedrrrrrs``` @@@@@rrun_with_rescue_ladderr Us d C}}S!H )#///K9J __\2 . 2 24;se9L MF?JxY[?\]?\!155tG!45?\K]((;'38K<<"rlGB wse_$$M &D-@Ov"wx'{D-QGK     fd166(&C D1::&C))+ "f     #/"&&'iik!.*#%#i2_  6!!)wqttfIcU-KL3qttfD.. .    fvYse&D E/4&D-b"cd.{D-Q\^efKO     f QTTF$qvvh&G H1::&C))+ "f     #/"*&'iik!.*#2#i2_  6!!){144& #-OP7144&SE22 2    f ADD63%&H I/4'T#.g#hi  T=+`g hF#'"&"*6li* _. :6(C CCE^s2)Nc t||||S)Nr)r )rrr max_retriesrs rrun_with_supervisorrs "$ WV LLrcPeZdZdZd dZd dZd dZddZddZddZ dddZ d Z y )TaskStateBridgezEMantiene _task_state.json sincronizado con el progreso real del flow.cXt|_||_||_|j |yr ) STATE_PATHrGrA station_ids _init_state)rKrApayloadrs rrNzTaskStateBridge.__init__s&  & !rc|j||jddgddggddddttjdzd}|j |y)Nr processingr)rArQrouterouteIdxstaterE transition_trvdemo_logs_completedlogsstarted_at_flow_sstarted_at_station_selapsed_at_flow_selapsed_at_station_s saved_at_wall)rArrrrJ)rKrrs rrzTaskStateBridge._init_states`||%%!#%!"$%!"$% t!34 " 5rc|jjr0 tj|jj dSiS#t $rYiSwxYwr2)rGrIr6r7r9rrQs rrRzTaskStateBridge._loadsX 99    zz$))"5"5w"5"GHH    s.A AActtjdz|d< |jjt j |dddy#t $r(}td|tj Yd}~yd}~wwxYw) Nrr"Fr rVr3r4z5[bridge] WARN: no se pudo escribir _task_state.json: file) rrrGrZr6r[rrFsysrJ)rKrr5s rrJzTaskStateBridge._savesu!$TYY[4%7!8o ` II Ea!P[b c ` I!MTWT^T^ _ _ `s3A B "BB c|j}|sy|jdgjt||d|ddd|d<|j | t d|j d|y#t$rYywxYw)Nr)r.rrirCrD)rRrjrcrrJrFrr)rKrrr s rrEzTaskStateBridge.append_log s JJL  VR ''))  fIef%&  1   Aekkm_Btf- .   sA>> B  B c|j}|sy||d<d|d<d|d<d|d<ttjdz|d<|j|y) Nrrrrrrrr")rRrrrJ)rK route_idxr s radvance_stationzTaskStateBridge.advance_station s_ JJL !* !' .$% ! t!34/ 1 rc|r|j|rdnd||j}|syd|d<||d<|j|y)Nrvrtdoner)rErRrJ)rKrvsummaryr s r mark_donezTaskStateBridge.mark_done+sE  OOIgw G JJL ' )  1 rc|jjr |jjyy#t$rYywxYwr )rGrIunlinkrrQs rclearzTaskStateBridge.clear5s@ 99       "   s8 AAN)rArwrrmrr)rrmrx)rrmrrwrrw)r*rr)rvrr.rw) rzr{r|r}rNrrRrJrEr+r/r2rrrrrs.O" *`* rrc Rtj|jd}t||}t|z }|j ddt |||}t}|d}|rt|||D cgc]} | d c} nd} t| g} | jd|d|d t|| r| jd d |d |d t|D]\} } | d}| jdgDcgc]}|d }}| jd|d|| r| j| | jd d|j!ddj#|| jdijdd}| jd d|d|j!dt%|| || \}}|su| jd|d|| r>| jdd|j!d|| j'd d!|d"|d#|||| t)|j*d$cS| jd%|d|| sz| jd&d'|j!d(|| jd)|d*|j*d+|j-d,| rK| jd&d-|j-d,| j'dd |d.|j-d,d/|| t)|j*d0Scc} wcc}w)1Nr3r4Tr>stationsrz[start] flow_id=u · dry_run=u · stations=rIzFlow u arrancado · dry_run=u · 6 estacionesrrz [station] u · agentes=u▶ Entrando estación u · agentes: z, rru👁 Supervisor u en posición · base PDF: PDF_z.pdfr z[ABORT] rrtrrFzFlow abortado en z: r)r+rAstationrlog caja_pathz[ok] rvu✓ u OK · z [done] flow u cerrado · caja=u · size=r>u-🎯 Flow completado · 6 estaciones · caja u OK · caja OK)r+rAr8r9)r6r7r9r0rrHr<r:rr?rcrorErr)r+rr r r/rwrGrv)r-rbridge_enabledrrArFrmetar6r rr8idxr7rr rrrrhs rrun_flowr>=sJjj--w-?@GWj1G G MM$M. ' *D ;DJHO]_Wg/JA$/J KcgFv CJJ!',wi}SQY]O\] &E'2H Qa"bc!(+ Wdm*1++h*CD*CQqy*C D ZuL >?   " "3 '   f(? }MZ^ZcZcdoZpYq&r s[[r266t]KF   f(8@_`c`i`i`k_llp&q r(wOC JJ#d3%0 1!!'T#))+iu+MN  *;C53%(HI$STW`cruvzvvsAB B U3%tC5)*    i4 }GC5)I J),,JJgY&7 {)DOOL]K^^_`a )'TUYUdUdUfTggh%ijwi|DOOrr6r[ INBOX_DIRPOLL_INTERVAL_S STOP_FLAGsortedglob with_suffixrrZoncersleep)rargsr-rf done_markers rmainrUps!ANN;|:`NaNN>2^N_NN8L7TNU <<>D $//* %%' *J  " 1*>SZZ P HHQK*dll; djjeA>? fX&$.A6 OI;f_,=]4<<. YZ      9 :  }56A--0K!!# )!&&2 3a6F  " "4::f5QR#S^e " f JqvvheF8,<+=> ?yy7 ?# r__main__r3r4)r rwryrwr )r,rmr-z Path | Noneryrwrx)r) rrwrrwrrwrrwrrryzlist[Hypothesis] | None) rrmr'Caja'rrwrrrylist[Hypothesis]) rrmrrWrrwrrlrrryrX)rrmrrWrrwrrlr,rlrrryr)r8z str | Noneryrwr3)r}) r`rwrrwrrwrrryztuple[bool, dict | None, str]r4)rr<rrmrrrrw) rr<rrmrrrr:ryr) rr<rrmrrr rrr:ryr)FT)r-rrrr;rryrm)=r} __future__rrCr6osr'rrrpathlibrrr__file__rrr8rJrrrLrKDEFAULT_MAX_RETRIESr)r&rrr!r0r:r<rrrrrr r6r9r;__annotations__r?rArGrprrrrrrrr rrr>rUrzr reconfigurerrrr`sT!D#  ' H~ * * = '> & & , , F  2#=<E<EF++d3-3-D b bNQ"7:"GJ"Ul"J<~8/38>B8GW8v3%)3<@3KO3TX3tf,0(/ '.1m?'*m?5Rm?`=K~(GTE8NvUp9Uv\=~" &   @DuD$<uDHXuDt,?;?M%(M 8MDTM \\~,Yf"$J zJJG,Fr