yj$ dZddlmZddlmZmZddlZddlZddlm Z m Z m Z ddl m ZdZed Gd d Zed Gd d Zd5dZd6dZdddddddddd d7d,Zd8d0Zd9d2Zd:d4ZdS);uKanban Swarm v1: thin swarm topology helpers on top of Kanban. This module intentionally does not introduce a second scheduler. It writes a small task graph into the existing Kanban kernel: planning root (completed immediately) ├─ parallel specialist workers (ready) └─ verifier (todo until all workers done) └─ synthesizer (todo until verifier done) The shared blackboard is also deliberately low-tech: structured JSON comments on the root task. That keeps all state in existing task_comments/task_events rows, so the dashboard, notifier, slash command, and dispatcher keep working without a new service. ) annotations) dataclassfieldN)AnyIterableOptional) kanban_dbz[swarm:blackboard] T)frozencpeZdZUdZded<ded<ded<eeZded<d Zd ed <d Z d ed<d S)SwarmWorkerSpecz)A single parallel worker card in a swarm.strprofiletitlebody)default_factory list[str]skillsrintpriorityNz Optional[int]max_runtime_seconds) __name__ __module__ __qualname____doc____annotations__rlistrrr=/home/ragecks/.hermes/hermes-agent/hermes_cli/kanban_swarm.pyr r st33LLLJJJ IIId333F3333H)-------rr cDeZdZUdZded<ded<ded<ded<d d Zd S) SwarmCreatedz%IDs produced by :func:`create_swarm`.r root_idr worker_ids verifier_idsynthesizer_idreturndict[str, Any]cR|jt|j|j|jdS)Nr"r#r$r%)r"rr#r$r%)selfs ras_dictzSwarmCreated.as_dict2s/|t//+"1    rN)r&r')rrrrrr+rrrr!r!)s]//LLL      rr!valuer field_namer&cZ|pd}|st|d|S)Nz is required)strip ValueError)r,r-texts r _require_textr3;s; KR   D 6J444555 Krr"goalc8d|d|dS)Nz7 ## Swarm protocol - Swarm root / shared blackboard: `z`. - Read sibling/parent handoffs from Kanban context before working. - Put machine-readable facts in completion metadata. - Put cross-worker notes on the root task using structured comments. - Goal:  r0)r"r4s r_swarm_contextr8Bs5 $.5 $ $ ::<<  $ $ $rzVerify swarm outputszSynthesize swarm outputszswarm-orchestratorscratch) root_titleverifier_titlesynthesizer_titletenant created_byworkspace_kindworkspace_pathridempotency_keyconnsqlite3.ConnectionworkersIterable[SwarmWorkerSpec]verifier_assigneesynthesizer_assigneer: Optional[str]r;r<r=r>r?r@rrrAc xt|d}t|d}t|d}t|}|stdt|dD]7\}}t|jd|dt|jd|d 8t j||p$d |d d d d|| | || | | |  }t|| d}t|tr}d| dgD}| d}| d}|r1|r/|r-t||t|t|St j||dd|t!|dt#||}g}|D]_}t j||j|jpd|z|j| |g||jp| | | |jpd |j }||`d|z}t j||||| ||| | | dg }d|z}t j||||| |g|| | | d g }t||||}t/||| d|d|iz!|S)"aCreate a durable Kanban swarm graph. The returned graph is immediately dispatchable: the planning root is marked ``done`` with topology metadata, parallel workers are ``ready``, the verifier waits for every worker, and the synthesizer waits for the verifier. r4rFrGzat least one worker is required)startzworkers[z ].profilez].titlezSwarm: rNPzKanban Swarm v1 planning/root card. This card is completed immediately so parallel workers can start while it remains the shared blackboard and audit anchor. Goal: ) rrassigneer>r=rrAr?r@topologyc0g|]}|t|Sr)r ).0xs r z create_swarm..s#JJJJc!ffJJJrr#r$r%r)z;Swarm topology planned; root remains the shared blackboard.kanban_swarm_v1)kindr4 worker_count)summarymetadatar/) rrrMr>parentsr=rr?r@rrzReview every worker handoff and blackboard update. Gate the swarm: complete only with metadata {"gate": "pass"} when evidence is sufficient; otherwise block with exact missing work.zrequesting-code-review) rrrMr>rXr=rr?r@rzwSynthesize the verified worker outputs into the final deliverable. Do not start until the verifier has passed the gate. humanizer)authorkeyr,)r3rr1 enumeraterrkb create_task splitlineslatest_blackboardget isinstancedictr!r complete_tasklenr8rrrrappendpost_blackboard_updater+)rBr4rDrFrGr:r;r<r=r>r?r@rrA worker_specsispecrootexistingr#r$r%context_suffix worker_id verifier_bodyverifiersynthesizer_body synthesizercreateds r create_swarmrtMs0 v & &D%&79LMM()=?UVV==L <:;;;\333994dl$;q$;$;$;<<<dj"7Q"7"7"78888 > AAdoo&7&7&:3B3&?AA    '%%   D*!t,,00<22    M% --     $D$//NJ%%N *)/r^3\!F].h));&$ $ 8     )$$$$ ?   ~  "%%()   H ?   .  % %%}   K4X{CCG   oo64.0  NrrZr[rct|dt|d}t|d}tj||ddd}tj|||t |zS) z:Append one structured update to the swarm root blackboard.r"rZr[)r[r,FT) ensure_ascii sort_keys)rZr)r3jsondumpsr] add_commentBLACKBOARD_PREFIX)rBr"rZr[r,payloads rrgrgsq'9%%% 68 , ,F U # #Cju55EUYZZZG >$=NQX=X Y Y YYrr'ci}i}tj||D]}|jpd}|ts& t j|ttd}n#t j$rYgwxYw| d}t|tr|s| d||<|j ||<|r||d<|S)zMerge structured blackboard comments on a root card. Later comments replace earlier values for the same key. ``_authors`` records the author of the winning value for traceability. r/Nr[r,_authors) r] list_commentsr startswithr{rxloadsreJSONDecodeErrorrarbr rZ)rBr"mergedauthorscommentrr|r[s rr`r`s F G#D'22 & &|!r011   jc*;&<&<&=&=!>??GG#    H kk%  #s## 3  kk'**s ~ %$z Ms.A00BBrawcTd|ddD}t|dkrtdg}t|dkr-|dr%d|ddD}t|d|d |d | S) z:Parse CLI ``--worker profile:title[:skill,skill]`` values.c6g|]}|Srr7)rPps rrRz$parse_worker_arg..s 2 2 21QWWYY 2 2 2r:z9worker must be profile:title or profile:title:skill,skillc^g|]*}||+Srr7)rPss rrRz$parse_worker_arg..s-FFFAGGIIF!''))FFFr,rrJ)rrrr)splitrer1r )rpartsrs rparse_worker_argr s 3 2 #q 1 1 2 2 2E 5zzA~~TUUUF 5zzQ58FFU1X^^C%8%8FFF 5858%(SY Z Z ZZr)r,r r-r r&r )r"r r4r r&r )rBrCr4r rDrErFr rGr r:rHr;r r<r r=rHr>r r?r r@rHrrrArHr&r!) rBrCr"r rZr r[r r,rr&r)rBrCr"r r&r')rr r&r )r __future__r dataclassesrrrxsqlite3typingrrr hermes_clir r]r{r r!r3r8rtrgr`rrrrrs #"""""(((((((( **********&&&&&&) $........ $        "$!%07 *#$(%)QQQQQQhZZZZ"6 [ [ [ [ [ [r