`gj$ HdZddlmZddlmZmZddlZddlZddlm Z m Z m Z ddl m ZdZed Gd d Zed Gd d ZddZddZdddddddddd ddZ ddZddZddZy)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)frozencheZdZUdZded<ded<ded<eeZded<d Zd ed <d Z d ed<y )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__rlistrrrJ/root/.hermes/venv/lib/python3.12/site-packages/hermes_cli/kanban_swarm.pyr r s83 L J Id3FI3Hc)--rr cBeZdZUdZded<ded<ded<ded<d dZy ) SwarmCreatedz%IDs produced by :func:`create_swarm`.r root_idr worker_ids verifier_idsynthesizer_idcr|jt|j|j|jdS)Nr"r#r$r%)r"rr#r$r%)selfs ras_dictzSwarmCreated.as_dict2s1||t/++"11   rN)returndict[str, Any])rrrrrr)rrrr!r!)s!/ L rr!cN|xsdj}|st|d|S)Nz is required)strip ValueError)value field_nametexts r _require_textr3;s. KR   D J<|455 Krc0d|d|jdS)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:  )r.)r"goals r_swarm_contextr7Bs* ..5Y7::<.  $rzVerify swarm outputszSynthesize swarm outputszswarm-orchestratorscratch) root_titleverifier_titlesynthesizer_titletenant created_byworkspace_kindworkspace_pathridempotency_keyc @t|d}t|d}t|d}t|}|s tdt|dD]9\}}t|jd|dt|j d|d ;t j||xsd |jd d d d|| | || | | |  }t||jd}t|trt|jdgDcgc]}|st|}}|jd}|jd}|r%|r#|r!t||t|t|St j||dd|t!|dt#||}g}|D]}t j||j |j$xsd|z|j| |g||j&xs| | | |j(xsd |j* }|j-|d|z}t j||||| ||| | | dg }d|z}t j||||| |g|| | | dg }t||||}t/||| d|j1d|iz |Scc}w)!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. r6verifier_assigneesynthesizer_assigneezat 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<rr@r>r?topologyr#r$r%r'z;Swarm topology planned; root remains the shared blackboard.kanban_swarm_v1)kindr6 worker_count)summarymetadatar-) rrrGr=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) rrrGr=rNr<rr>r?rzwSynthesize the verified worker outputs into the final deliverable. Do not start until the verifier has passed the gate. humanizer)authorkeyr0)r3rr/ enumeraterrkb create_task splitlineslatest_blackboardget isinstancedictr r! complete_tasklenr7rrrrappendpost_blackboard_updater))connr6workersrBrCr9r:r;r<r=r>r?rr@ worker_specsispecrootexistingxr#r$r%context_suffix worker_id verifier_bodyverifiersynthesizer_body synthesizercreateds r create_swarmrmMs0 v &D%&79LM()=?UV=L :;;\394dllhqc$;<djjHQCw"789 >> Agdoo&7&:3B&?%@A V  '%% D*!t,002    M% - $D$/NJ%NN **))/r^3\\!F]].h));;&$ $ 8 8   )$%$ ?   ~~  "%%() H ?   ..  % %%} K4X{CG   oo64.0  NqKs J Jct|dt|d}t|d}tj||ddd}tj|||t |zS) z:Append one structured update to the swarm root blackboard.r"rPrQ)rQr0FT) ensure_ascii sort_keys)rPr)r3jsondumpsrS add_commentBLACKBOARD_PREFIX)r^r"rPrQr0payloads rr]r]sZ'9% 68 ,F U #Cjju5EUYZG >>$=NQX=X YYrci}i}tj||D]}|jxsd}|jts) t j |ttd}|jd}t|tr|ss|jd||<|j||<|r||d<|S#t j$rYwxYw)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-NrQr0_authors) rS list_commentsr startswithrtrqloadsr[JSONDecodeErrorrWrXr rP)r^r"mergedauthorscommentrrurQs rrVrVs F G##D'2 &||!r01  jjc*;&<&=!>?Gkk% #s#3 kk'*s ~~  &$z M##   s%B<<CCc||jddDcgc]}|j}}t|dkr tdg}t|dk(rE|dr@|djdDcgc]#}|js|j%}}t |d|d|d|Scc}wcc}w) z:Parse CLI ``--worker profile:title[:skill,skill]`` values.:z9worker must be profile:title or profile:title:skill,skill,rrD)rrrr)splitr.r[r/r )rawppartsrss rparse_worker_argr s!$ #q 1 21QWWY 2E 2 5zA~TUUF 5zQ58%*1X^^C%8FAGGI!'')FF 5858%(SY ZZ 3 GsB42B9B9)r0r r1r r*r )r"r r6r r*r )r^sqlite3.Connectionr6r r_zIterable[SwarmWorkerSpec]rBr rCr r9 Optional[str]r:r r;r r<rr=r r>r r?rrrr@rr*r!) r^rr"r rPr rQr r0rr*r)r^rr"r r*r+)rr r*r )r __future__r dataclassesrrrqsqlite3typingrrr hermes_clir rSrtr r!r3r7rmr]rVrrrrrs #( **&) $... $   "$!%07 *#$(%)Q Q Q' Q  Q  QQQQ QQQ"QQ#Q !QhZ Z Z  Z Z  Z Z"6 [r