PL j:BdZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZejeZdZd Zejd ejZeGd d Zd,dZd-dZd.dZd/dZd0dZd0dZd1dZd2d Z ddd!d3d'Z!dd(d4d+Z"dS)5uHKanban decomposer — fan a triage task out into a graph of child tasks. Invoked by ``hermes kanban decompose [task_id | --all]`` and the auto-decompose path in the gateway dispatcher loop. Reads the user's profile roster (with descriptions) and asks the auxiliary LLM to return a task graph in JSON. Then atomically creates the children, links them under the root, and flips the root ``triage -> todo``. The root task stays alive and becomes the parent of every leaf child, so when the whole graph completes the root wakes back up — its assignee (the orchestrator profile) gets a chance to judge completion and add more tasks if the work isn't done yet. Design notes ------------ * Mirrors the shape of ``hermes_cli/kanban_specify.py``: lazy aux client import inside the function, lenient response parse, never raises on expected failure modes. * The system prompt sees the *configured* profile roster — names plus descriptions plus the default fallback. Profiles without a description are still listed (with a note) so the orchestrator can match on name as a fallback, but the user has an obvious incentive to describe them. * ``fanout=false`` collapses to the same effect as ``kanban specify``: we tighten the body and flip ``triage -> todo`` as a single task, no children created. This makes ``decompose`` a strict superset of ``specify`` from the user's perspective. * If the LLM picks an assignee that doesn't exist as a profile, we rewrite it to the configured ``default_assignee`` (or the default profile if unset). A child task NEVER ends up with ``assignee=None``. ) annotationsN) dataclass)Optional) kanban_db)profilesuYou are the Kanban decomposer for the Hermes Agent board. A user dropped a rough idea into the Triage column. Your job is to break it into a small graph of concrete child tasks and route each one to the best- matching profile from the available roster. You will be given: - The original task title and body - The list of available profiles (each with name + description) - The fallback "default_assignee" used when no profile fits Output a single JSON object with this exact shape: { "fanout": true, "rationale": "", "tasks": [ { "title": "", "body": "", "assignee": "", "parents": [, ...] }, ... ] } Rules: - "parents" is a list of INDICES (0-based) into this same "tasks" list, expressing actual data dependencies. Tasks with no parents run in PARALLEL. Tasks with parents wait until every parent completes. - Prefer parallelism. If two tasks can be done independently, give them no parents so the dispatcher fans them out at once. - Use 2-6 tasks for normal work. Don't create 20 tiny tasks. Don't cram everything into 1 task. - Pick assignees from the roster by matching the task to the profile's DESCRIPTION (not just the name). When nothing matches well, use null and the system will route to the default_assignee. - Each child task body is what a fresh worker will read with no other context — be specific about goal, approach, and acceptance criteria. When the task is genuinely a single unit of work (no useful decomposition), return: { "fanout": false, "rationale": "", "title": "", "body": "" } In that case the task stays as one work item, just with a tightened spec. No preamble, no closing remarks, no code fences. Output only the JSON object. zTask id: {task_id} Title: {title} Body: {body} Available profiles (assignees you may pick from): {roster} Default assignee (used when no profile fits a task): {default_assignee} z^```(?:json)?\s*|\s*```$c`eZdZUdZded<ded<dZded<dZded <d Zd ed <d Zd ed<d S)DecomposeOutcomez+Result of decomposing a single triage task.strtask_idboolokreasonFfanoutNzlist[str] | None child_ids Optional[str] new_title) __name__ __module__ __qualname____doc____annotations__rrrr?/home/kuhnn/.hermes/hermes-agent/hermes_cli/kanban_decompose.pyr r |sn55LLL HHHFF"&I&&&&#I######rr textr limitintreturncLt||kr|S|d|dz dzS)Nu…)len)rrs r _truncater#s0 4yyE  %!) u $$rrawOptional[dict]c|sdStd|}|d}|d}|dks |dks||krdS|||dz} t j|}n#tt jf$rYdSwxYwt|tsdS|S)Nr{}r!) _FENCE_REsubstripfindrfindjsonloads ValueErrorJSONDecodeError isinstancedict)r$strippedfirstlast candidatevals r_extract_json_blobr:s t}}R--H MM#  E >>#  D {{dbjjDEMMt)*Ij## , -tt c4 t Js>BB-,B-ctjdp tjdpdS)z0Mirror of ``hermes_cli.kanban._profile_author``.HERMES_PROFILEUSER decomposer)osenvirongetrrr_profile_authorrBs9 '((  :>>& ! !  rr4cL ddlm}|piS#t$ricYSwxYw)Nr load_config)hermes_cli.configrE ExceptionrDs r _load_configrHsN111111{}}""  s  ##cfgcPt|tr|dini}|dpd}|r( t j|r|Sn#t $rYnwxYw t jpdS#t $rYdSwxYw)zResolve which profile owns decomposition. Falls back to the active default profile when ``kanban.orchestrator_profile`` is unset, so a task is never stranded for lack of an orchestrator. kanbanorchestrator_profilerdefaultr3r4rAr, profiles_modprofile_existsrGget_active_profile_namerI kanban_cfgexplicits r_resolve_orchestrator_profilerUs +5S$*?*?G2&&&RJ566<"CCEEH *844      D 355BB yy$A11 A>=A>B B%$B%cPt|tr|dini}|dpd}|r( t j|r|Sn#t $rYnwxYw t jpdS#t $rYdSwxYw)zGResolve which profile catches child tasks the orchestrator can't route.rKdefault_assigneerrMrNrRs r_resolve_default_assigneerYs*4S$*?*?G2&&&RJ1228b??AAH *844      D 355BB yyrVtuple[list[dict], set[str]]cg}t} tj}n6#t$r)}td|||fcYd}~Sd}~wwxYw|D]m}|jpd}||j |p d|j dt|d| |j n||fS)zReturn (roster_for_prompt, valid_assignee_names). Each roster entry is ``{name, description, has_description}``. The valid-set is used after the LLM responds to rewrite invalid assignees to the default fallback. z&decompose: failed to list profiles: %sNrz(no description; profile named ))name descriptionhas_description) setrO list_profilesrGloggerwarningr^r,appendr]r add)rostervalid all_profilesexcpdescs r _build_rosterrlsFeeE#133 ?EEEu} #**,, FP#PQV#P#P#P#Dzz      !& 5=s& AAAArf list[dict]c |sdSg}|D]7}|drdnd}|d|d|d|d8d |S) Nu: (no profiles installed — decomposer cannot route work)r_ru ⚠ undescribedz - r]z: r^ )rdjoin)rflinesentrytags r_format_rosterrts LKK EJJ+,Dbb2D HE&MH3HH% 2FHHIIII 99U  r)authortimeoutr rurrv Optional[int]c  #$tj5}tj||}dddn #1swxYwY|t|ddS|jdkrt|dd|jdSt }t |}t|}t\}} ddl m } m } nC#t$r6} td | t|dd cYd} ~ Sd} ~ wwxYw | d \} }nC#t$r6} td | t|dd cYd} ~ Sd} ~ wwxYw| |st|dd St|jt%|jpddt%|jpddt+||} | jj|dt2dd|dgdd|pd| pd}nY#t$rL} td|| t|ddt7| jcYd} ~ Sd} ~ wwxYw |jdjjpd}n#t$rd}YnwxYwtA|}|t|ddStC|"d}|p tG}|s|"d}|"d}tI|tJr(|&r|&nd}tI|tJr|&r|nd}||t|ddStj5}tj'||||| }dddn #1swxYwY|st|dd!St|d"d#d|$S|"d%pg$tI$tPr$st|dd&Sg}tS$D]\#}tI|tTst|dd'#d(cS|"d}tI|tJr|&st|dd'#d)cS|"d}tI|tJsd}|"d*}tI|tJr|&s|}n'|| vr!td+|#|||}n|}|"d,pg} tI| tPsg} #$fd-| D}!|+|&dd.|&||!d/ tj5}tj,|||||0}"dddn #1swxYwYn~#tZ$r} t|dd1| cYd} ~ Sd} ~ wt$rK} t.d2|t|dd3t7| jcYd} ~ Sd} ~ wwxYw|"t|dd4St|d"d5t_|"d6d"|"7S)8uGDecompose a triage task into a graph of child tasks. Returns an outcome describing what happened. Never raises for expected failure modes (task not in triage, no aux client configured, API error, malformed response, decomposer returned fanout=true with empty task list) — those surface via ``ok=False``. NFzunknown task idtriageztask is not in triage (status=r\r)get_auxiliary_extra_bodyget_text_auxiliary_clientz-decompose: auxiliary client import failed: %szauxiliary client unavailablekanban_decomposerz/decompose: get_text_auxiliary_client failed: %szno auxiliary client configuredriz (no body)i)r titlebodyrfrXsystem)rolecontentuserg333333?)modelmessages temperature max_tokensrv extra_bodyz&decompose: API call failed for %s (%s)z LLM error: zLLM returned malformed JSONrr}r~z3decomposer returned fanout=false with no title/body)r}r~ruz)task moved out of triage before promotionTzsingle task (no fanout))rrtasksz5decomposer returned fanout=true with empty tasks listztasks[z] is not an objectz].title is missing or emptyassigneeuYdecompose: task %s child %d picked unknown assignee %r — routing to default_assignee %rparentscg|]<}t|td|cxkrtk1nn|k:|=S)r)r3rr").0rjidx raw_taskss r z"decompose_task..s\kkkqz!S/A/Aka1F]F]F]F]sS\~~F]F]F]F]F]bcgjbjbjbjbjbjr)r}r~rr) root_assigneechildrenruzDB rejected graph: zdecompose: DB error on task %sz DB error: z-task moved out of triage before decompositionzdecomposed into z children)rr)0kbconnectget_taskr statusrHrUrYrlagent.auxiliary_clientrzr{rGrbdebug_USER_TEMPLATEformatidr#r}r~rtchat completionscreate_SYSTEM_PROMPTinfotyperchoicesmessagerr:r rArBr3r r,specify_triage_tasklist enumerater4rddecompose_triage_taskr1 exceptionr")%r rurvconntaskrI orchestratorrXrf valid_namesrzr{riclientruser_msgrespr$parsedr audit_authorrnew_body title_valbody_valr rrrr}r~rchosenr clean_parentsrrrs% @@rdecompose_taskrs2  *{4))*************** |0ABBB {h UMT[MMM    ..C055L055'//FKP          PPP DcJJJ0NOOOOOOOOPP112EFF  PPP FLLL0NOOOOOOOOP~U~0PQQQ$$ (b#.. ty/K 6 6f%%) %HT{&--!n==H55Ns//119T.    TTT 4gs    0Rd3ii>P0R0RSSSSSSSS T l1o%-3   $ $F ~0MNNN &**X&& ' 'F._..L  JJw'' ::f%%)3Is)C)Cc HYHYcIOO%%%_c )(C88WX^^=M=MW88SW  !1# U Z\\ T'# B                # K  T4I     7##)rI i & & i  US   H **# # U%&& # @ @ @ @    '""%%% U[[]] # I I I I   yy  $$$ D99Z(((C(( 0@0@ %FF [ ( ( KK1h(8    &FFF))I&&,"'4(( GkkkkkGkkk [[]]4C4(JJLL$        S Z\\ T0*!# I                MMM0Kc0K0KLLLLLLLL SSS97CCC0QT#YY=O0Q0QRRRRRRRRS UK    C#i..CCCy   s8<<9C D +C=7D=DD E+E EE >H IAIII"I<< J  J #O  O O ,X1?X% X1%X))X1,X)-X11 Z,;YZ, Z,!AZ'!Z,'Z,)tenantr list[str]ctj5}tj|d|d}dddn #1swxYwYd|DS)z/Return task ids currently in the triage column.ryi)rrrNcg|] }|j Sr)r)rrows rrz#list_triage_ids..s # # #sCF # # #r)rr list_tasks)rrrowss rlist_triage_idsrs  }                     $ #d # # ##s 9==)rr rrrr )r$r rr%)rr )rr4)rIr4rr )rrZ)rfrmrr )r r rurrvrwrr )rrrr)#r __future__rr/loggingr?re dataclassesrtypingr hermes_clirrrrO getLoggerrrbrrcompile MULTILINEr*r r#r:rBrHrUrYrlrtrrrrrrs""H#"""""  !!!!!!&&&&&&//////  8 $ $6r  BJ2BL A A  $$$$$$$ $%%%% $*     2!! ssssssl04 $ $ $ $ $ $ $ $r