SiUdZddlmZddlZddlmZmZddlmZddl m Z ddl m Z e e ZegdZd ed <d Zd ed <dZd ed<eGddZeGddZGddZy)uOutils/delegate_controller.py — 서브에이전트 격리 위임 컨트롤러.) annotationsN)ThreadPoolExecutor as_completed) dataclass)Any) get_logger)delegateclarifymemory send_messagezfrozenset[str] BLOCKED_TOOLSint MAX_DEPTHMAX_CONCURRENTcFeZdZUdZded<dZded<dZded<d Zd ed <y) SubAgentTasku1서브에이전트에 위임할 단일 태스크.strgoalN str | Nonecontextlist[str] | Nonetoolsets2rmax_iterations)__name__ __module__ __qualname____doc____annotations__rrrJ/home/jay/workspace/.worktrees/task-2117-dev1/utils/delegate_controller.pyrrs); IGZ!%H%NCr#rc^eZdZUdZded<ded<dZded<d Zd ed <d Zded <dZded<y)SubAgentResultu!서브에이전트 실행 결과.r task_indexrstatusNrsummarygfloatduration_secondsr api_callserror) rrrr r!r)r+r,r-r"r#r$r&r&s8+O KGZ!e!IsE:r#r&c:eZdZdZdd dZd dZd dZd dZd dZy)DelegateControlleruL서브에이전트 배치 실행 및 위임 깊이/동시 실행 수 제어.c||_g|_tj|_tj |_yN)_depth_active_children threadingLock_children_lockEvent _interrupted)self parent_depths r$__init__zDelegateController.__init__-s/' +-'nn.%OO-r#c|jtk\rddtd|jfS|j5t|jt k\rddt dfcdddS dddy#1swYyxYw)u6위임 가능 여부와 거부 이유를 반환한다.Fu최대 위임 깊이(u) 초과: 현재 깊이=u최대 동시 자식(u) 초과N)TOK)r2rr6lenr3rr9s r$ can_delegatezDelegateController.can_delegate3s ;;) #1)aq '=>>>s c *|sgSddlm}g}tt|t}t |5}i}t |D]\}}|jjr|jt|dd>t|j|j|j|jxsd|j } |j"5|j$j|ddd|j'|| |j(d z|j|} ||| <t+|D]} || } | j-} |j"5||j$vr|j$j3|ddd|j| t4j7d | j8| j:| j< ddd|j?d |S#1swYxYw#t.$r!} t|d t1| } Yd} ~ d} ~ wwxYw#1swYxYw#|j"5||j$vr|j$j3|dddw#1swYwxYwxYw#1swYxYw)uG배치 서브에이전트를 ThreadPoolExecutor로 병렬 실행한다.r) run_subagent) max_workers interruptedz&Controller interrupted before dispatch)r'r(r-N)rrrrr-z SubAgent[%d] status=%s dur=%.2fsc|jSr1)r')rs r$z(DelegateController.run..rs 1<<r#)key) utils.delegate_runnerrEminr>rr enumerater8is_setappendr&rrrrCrrr6r3submitr2rresult Exceptionrremoveloggerdebugr'r(r+sort) r9tasksrEresultsworkersexecutor future_mapidxtaskpatchedfutresexcs r$runzDelegateController.runBsUI6(*c%j.1 G 4$ s)+J&u- & T$$++-NN&'*#0"J& LL!..t}}=E#'#6#6  ((6))0056oolGT[[1_dN_N_ade"% 3+ &.$J/ s o>**,C,,>$"7"77 1188=>s# ?QTQ[Q[]`]q]qr s3$ sL  / 0)66!Y(CsSVxXCY>>,,>$"7"77 1188=>>>A$ s$ ssB"J G40AJ ?H J *H.AJ 4G> 9J  H+ H&!H:&H++H:.H7 3J : J*I: 1 J:J?JJ  Jcx|jjtjd|jy)u8모든 활성 자식에게 인터럽트를 전파한다.z2DelegateController: interrupt broadcast (depth=%d)N)r8setrVrWr2r?s r$interrupt_childrenz%DelegateController.interrupt_childrenus'  I4;;Wr#N)r)r:rreturnNone)rhztuple[bool, str])rrrhz list[str])rYzlist[SubAgentTask]rhzlist[SubAgentResult])rhri) rrrr r;r@rCrdrgr"r#r$r/r/*s V. ? 1fXr#r/)r __future__rr4concurrent.futuresrr dataclassesrtypingr utils.loggerrrrV frozensetr r!rrrr&r/r"r#r$rpsU"?!# H  )*[ \ ~\ 3    NXNXr#