sj2 BdZddlmZddlmZmZddlZddlZddlm Z m Z m Z ddl m ZdZed Gd d Zed Gd d Zd:dZd;dZdd6Zd?d7Zd@d9ZdS)AuKanban 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/agent/.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 $ $ ::<<  $ $ $rconnsqlite3.Connectionsummarymetadatar'boolc ddl}t|}|d||f}|jdkrdSt j||d||}t j||dd|ddpdd | d S) uInline blocked→done CAS flip + event insert for the swarm root. Runs INSIDE create_swarm's outer write_txn, so it must not call ``kb.complete_task`` — that helper opens its own transaction and fires post-commit side effects (workspace cleanup, failure-counter clear, ``recompute_ready``) that would execute while the outer transaction can still roll back. Instead we do the minimal durable writes here and let the caller run ``recompute_ready`` after the outer commit. rNa UPDATE tasks SET status = 'done', completed_at = ?, claim_lock = NULL, claim_expires= NULL, worker_pid = NULL WHERE id = ? AND status = 'blocked' F completed)outcomer;r<i) result_lenr;)run_idT)timerexecuterowcountkb_synthesize_ended_run _append_event)r9r"r;r<_timenowcurrCs r_activate_root_inlinerMMs  ejjll  C ,,  g  C |qu  %  F WTcT]%:d;;  4rzVerify swarm outputszSynthesize swarm outputszswarm-orchestratorscratch) root_titleverifier_titlesynthesizer_titletenant created_byworkspace_kindworkspace_pathridempotency_keyworkersIterable[SwarmWorkerSpec]verifier_assigneesynthesizer_assigneerO Optional[str]rPrQrRrSrTrUrrrVc d}d}tj|5t|||||||||| | | | | }tj||j}|\|jdkrQt ||j|d|t|j dstd d }dddn #1swxYwY|rtj |tj||j}tj ||j}tj d |jtj|r|jnd|r|jnd| |S) zCAtomically create a durable, immediately dispatchable Kanban swarm.z;Swarm topology planned; root remains the shared blackboard.F) r4rWrYrZrOrPrQrRrSrTrUrrVNblockedkanban_swarm_v1)kindr4 worker_count)r;r<z/could not activate the completed swarm topologyTkanban_task_completed)boardassigneerCr;)rG write_txn_create_swarm_uncommittedget_taskr"statusrMr0lenr# RuntimeErrorrecompute_ready latest_run_fire_kanban_lifecycle_hookget_current_boardrcid)r9r4rWrYrZrOrPrQrRrSrTrUrrVactivation_summary activatedcreatedrootruns r create_swarmrts& FI d  + /!5!)/!))+    {411   y 8 8(*- JJLL$'(:$;$;    V##TUUUI=>  4   {411mD'/22 & # O&((&*4T]] *366d&      NsBB;;B?B?c (t|d}t|d}t|d}t|}|stdt|dD]7\}}t|jd|dt|jd|d 8t j||p$d |d d d d|| | || | d| |  }t|| d}t|tr}d| dgD}| d}| d}|r1|r/|r-t||t|t|St||}g}|D]_}t j||j|jpd|z|j| |g||jp| | | |jpd |j }||`d|z}t j||||| ||| | | dg }d|z}t j||||| |g|| | | dg }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. r4rYrZzat least one worker is requiredr?)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: r]) rrrcrSrRrrVinitial_statusrTrUtopologyc0g|]}|t|Sr)r ).0xs r z-_create_swarm_uncommitted..s#JJJJc!ffJJJrr#r$r%r)r/) rrrcrSparentsrRrrTrUrrzReview 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) rrrcrSr~rRrrTrUrzwSynthesize the verified worker outputs into the final deliverable. Do not start until the verifier has passed the gate. humanizer)authorkeyr,)r3rr1 enumeraterrrG create_task splitlineslatest_blackboardget isinstancedictr!r r8rrrrappendpost_blackboard_updater+)r9r4rWrYrZrOrPrQrRrSrTrUrrV worker_specsispecrrexistingr#r$r%context_suffix worker_id verifier_bodyverifiersynthesizer_body synthesizerrqs rrerest0 v & &D%&79LMM()=?UVV==L <:;;;\333994dl$;q$;$;$;<<<dj"7Q"7"7"78888 > AAdoo&7&7&:3B3&?AA    ' %%!   D,!t,,00<22  $D$//NJ%%N *)/r^3\!F].h));&$ $ 8     )$$$$ ?   ~  "%%()   H ?   .  % %%}   K4X{CCG   oo64.0  Nrrrrct|dt|d}t|d}tj||ddd}tj|||t |zS) z:Append one structured update to the swarm root blackboard.r"rr)rr,FT) ensure_ascii sort_keys)rr)r3jsondumpsrG add_commentBLACKBOARD_PREFIX)r9r"rrr,payloads rrrQsq'9%%% 68 , ,F U # #Cju55EUYZZZG >$=NQX=X Y Y YYrci}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/Nrr,_authors) rG list_commentsr startswithrrloadsrhJSONDecodeErrorrrr r)r9r"mergedauthorscommentrrrs rrrbs 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)r{ps rr}z$parse_worker_arg..s 2 2 21QWWYY 2 2 2r:z9worker must be profile:title or profile:title:skill,skillc^g|]*}||+Srr7)r{ss rr}z$parse_worker_arg..s-FFFAGGIIF!''))FFFr,rr?)rrrr)splitrhr1r )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 ) r9r:r"r r;r r<r'r&r=)r9r:r4r rWrXrYr rZr rOr[rPr rQr rRr[rSr rTr rUr[rrrVr[r&r!) r9r:r"r rr rr r,rr&r)r9r:r"r r&r')rr r&r )r __future__r dataclassesrrrsqlite3typingrrr hermes_clir rGrr r!r3r8rMrtrerrrrrrrs #"""""(((((((( **********&&&&&&) $........ $        "0000t!%07 *#$(%)DDDDDD\!%07 *#$(%)GGGGGGTZZZZ"6 [ [ [ [ [ [r