(*))+,&  & H%& JJ,.>?BLx'(2BMMMt4 Ict|S)uI격리된 WORKSPACE를 사용하는 chain_manager 모듈을 반환한다.)r%)rs r$r#r#<s x ((r&c<|dz dz }|jdd|S)u"체인 파일 저장 디렉토리.rrTr)r )rds r$ chains_dirr*Bs( 8h&AGGD4G( Hr&chain_idtasksstatus max_tasksscopewatchdog_cron_idc | dddddddddg}|dtjj||||d }|||d <|S) u.테스트용 체인 데이터를 생성한다.Nzmemory/tasks/dispatch-001.md dev1-teampendingautoorder task_fileteamr-task_idgate started_at completed_atanur+ created_by created_atr-r/r.r,r0)rnow isoformat)r+r,r-r.r/r0datas r$_make_chain_datarEOst };##" $   lln..0D##3  Kr&r*rDc|d}|jdr|d}nd|d}||z }|jtj|ddd|S) uB체인 데이터를 파일로 저장하고 경로를 반환한다.r+chain-.jsonF ensure_asciiindentutf-8encoding) startswith write_textjsondumps)r*rDr+filenamers r$ _write_chainrUss`JH8$Zu%H:U+  DOODJJt%BWOU Kr&c.eZdZdZdZdZdZdZdZy) TestCreateu&cmd_create() 서브커맨드 테스트cddddddddd dg}tjd tj|d d d }t j |d5}t }d|_d|_||j_ |j|ddd|dz }|jsJtj|jd} | dd k(sJ| ddk(sJ| dd k(sJ| dd k(sJ| dd k(sJt| ddk(sJ| dd} | ddk(sJ| dJ| dJ| d Jy#1swYxYw)!uD정상 생성: 체인 파일이 올바른 스키마로 생성된다.r2memory/tasks/t1.mdr3r5r7r8r9r;rIzmemory/tasks/t2.md dev2-teamnonezchain-20260307-001테스트 범위r> r+r,r/r@r. subprocessrz{"cron_id": "cron-abc123"}Nzchain-chain-20260307-001.jsonrMrNr+r-activer/r@r.r,r4r:r<r=)argparse NamespacerRrSrobjectr returncodestdoutrun return_value cmd_createexistsloads read_textlen) selfr#rr*r,argsmock_sub mock_result chain_filerDts r$test_create_normalzTestCreate.test_create_normals&:KY_ `&:KY_ ` !!)**U#$  \\"l + x#+K%&K "!=K (3HLL % MM$    "AA   """zz*...@AJ#7777H~)))G} 2222L!U***K B&&&4=!Q&&& M! {i'''|###&&& (((+  s ;D>>Ecdddddg}tjdtj|ddd }t j |d 5}t }d |_tjd di|_||j_ |j||jjsJ ddd|dz }tj|jd} d| vsJy#1swY:xYw)ubcreate 성공 시 cokacdir watchdog cron이 등록되고 cron_id가 체인 파일에 저장된다.r2rYr3r5rZzchain-cron-testucron 테스트r>r^r_r`rcron_idzcron-watchdog-001Nzchain-chain-cron-test.jsonrMrNr0)rbrcrRrSrrdrrerfrgrhricalledrkrl rnr#rr*r,rorprqrrrDs r$#test_create_registers_watchdog_cronz.TestCreate.test_create_registers_watchdog_crons+?^def!!&**U#"  \\"l + 'x#+K%&K "!%Y8K,L!MK (3HLL % MM$ <<&& && ' ">> zz*...@A!T))) ' 's A(C..C7cdtdDcgc]}|dzd|dddd}}tjdtj|d d d }t j t5}|j|d d d jjdk(sJy cc}w#1swY*xYw)u,max_tasks 초과 시 exit 1이 발생한다.r2memory/tasks/t.mdr3r5rZzchain-overflowu초과 테스트r>r_N) rangerbrcrRrSpytestraises SystemExitrivaluecode)rnr#rir,roexc_infos r$test_create_max_tasks_exceededz)TestCreate.test_create_max_tasks_exceededs1X !eN1#S*A;`f g  !!%**U#$  ]]: & ( MM$  ~~""a'''   sB!+B&&B/cdddddg}tjdtj|ddd }t j |d 5}t }d |_d |_||j_ |j|dddtjt5}|j|dddjj dk(sJy#1swYXxYw#1swY1xYw)u9동일 chain_id 중복 생성 시 exit 1이 발생한다.r2rYr3r5rZz chain-dupu중복 테스트r>r^r_r`rz{"cron_id": "cron-001"}N)rbrcrRrSrrdrrerfrgrhrirrrrr) rnr#rr*r,rorprqrs r$test_create_duplicate_chain_idz)TestCreate.test_create_duplicate_chain_ids+?^def!! **U#$  \\"l + x#+K%&K "!:K (3HLL % MM$   ]]: & ( MM$  ~~""a'''    s ;C(C*C'*C3ctjddddd}tjt5}|j |dddj jdk(sJy#1swY%xYw) u0잘못된 tasks JSON 시 exit 1이 발생한다.zchain-bad-jsonz{not valid json}uJSON 오류 테스트r>r^r_Nr2)rbrcrrrrirr)rnr#rrors r$test_create_invalid_tasks_jsonz)TestCreate.test_create_invalid_tasks_jsonsj!!%$)  ]]: & ( MM$  ~~""a'''  s A**A3N) __name__ __module__ __qualname____doc__rtryrrrr&r$rWrWs0#)J*2($(. (r&rWc eZdZdZ ddedededzdedef dZd Zd Z d Z d Z d Z dZ dZdZdZdZdZdZy)TestNextu$cmd_next() 서브커맨드 테스트Nr*r+r, chain_statusr c .|6ddddddtjjddd d d d dddddg}|d tjj|ddd|d}||dz }|jt j |dd d|S)u2테스트용 체인 파일을 생성하는 헬퍼.Nr2memory/tasks/task-001.mdr3running task-10.1r5r6rImemory/tasks/task-002.mdr[r4r>u 테스트r^zcron-watch-001r+r@rAr-r/r.r0r,rHFrJrMrNrrBrCrQrRrS)rnr*r+r,rrDrs r$ _setup_chainzTestNext._setup_chains =!;''*""*,,.":":"<$( !;''#""&$( E.!",,.224"  0  xj..  4eAFQXY r&c||j|tjd}|dz dz }|jdd|dz j dd |j ||j }tj|j}|d d k(sJ|d dk(sJ|ddk(sJd|vsJy)uA다음 pending task가 있으면 action=dispatch를 반환한다.rr:rreportsTr task-10.1.mdu작업 완료. 성공.rMrNactiondispatchr8rr9r[r+N rrbrcr rQcmd_next readouterrrRrkout rnr#rr*capsysro reports_dircapturedoutputs r$test_next_returns_dispatchz#TestNext.test_next_returns_dispatch2s *%!!+6)I5 $6 ~ %112JU\1] D$$&HLL)h:---k"&@@@@f~,,,V###r&c*|j|tjd}|dz dz }|jdd|dz j dd |j ||j }tj|j}|d d k(sJ|d dk(sJ|ddk(sJ|dz } tj| jd } | ddk(sJtd| dD} | ddk(sJ| ddk(sJy)u]gate=auto 조건에서 보고서에 FAIL 키워드가 있으면 재위임(retry)한다 (F12).rrrrTrru&작업 완료. QC FAIL: 오류 발견.rMrNrr retry_attemptr2r:chain-test.jsonr-rac3JK|]}|jddk(s|ywr:rNr.0rss r$ z.]s WquuY7G;7V1W##r, retry_countrN) rrbrcr rQrrrRrkrrlnext) rnr#rr*rrorrrrrrD target_tasks r$ test_next_qc_fail_triggers_retryz)TestNext.test_next_qc_fail_triggers_retryEs: *%!!+6)I5 $6 ~ %112Zel1m D$$&HLL)h:---o&!+++i K/// "33 zz*...@AH~)))Wd7mWW =)Q...8$ 111r&cH|j|tjd}|dz dz }|jdd|dz j dd |j ||j }tj|j}|d d k(sJy )uQgate=auto 조건에서 'QC FAIL (범위 외)'는 체인을 stall하지 않는다.rrrrTrruQ작업 완료. QC FAIL (범위 외 기존 테스트 1건 — 에스컬레이션).rMrNrrNrrs r$-test_next_qc_fail_out_of_scope_does_not_stallz6TestNext.test_next_qc_fail_out_of_scope_does_not_stallbs *%!!+6)I5 $6 ~ %11 _jq 2  D$$&HLL)h:---r&c ddddddtjjddd d d d dddddg}|j|| t j d}|dz dz }|j dd|dz jdd|j||j}tj|j} | ddk(sJy)uUgate=none이면 보고서 내용에 관계없이 다음 pending task를 반환한다.r2rr3r task-20.1r\Nr6rIrr[r4r,rrrTr task-20.1.mdu&QC FAIL 가 있어도 무시해야 함rMrNrr rrBrCrrbrcr rQrrrRrkr rnr#rr*rr,rorrrs r$test_next_gate_none_skips_qcz%TestNext.test_next_gate_none_skips_qcts7##&&lln668 $ 7##" $  , *E2!!+6)I5 $6 ~ %112Zel1m D$$&HLL)h:---r&c ddddddtjjddg}|j|| t j d }|d z d z }|j d d |dz jddtj|d5}t} d| _ d| _ | |j_|j|ddd|j!} t#j$| j&} | ddk(sJd| vsJ|dz } t#j$| j)d} | ddk(sJy#1swY}xYw)ua다음 pending task가 없으면 action=chain_complete를 반환하고 체인이 completed된다.r2rr3rz task-30.1r5Nr6rrrrTrz task-30.1.md작업 완료.rMrNr`rrchain_completer+rr- completed)rrBrCrrbrcr rQrrdrrerfrgrhrrrRrkrrl)rnr#rr*rr,rorrprqrrrrrDs r$test_next_chain_completez!TestNext.test_next_chain_completesj7##&&lln668 $    *E2!!+6)I5 $6 ~ %112BW1U \\"l + x#+K%&K "!#K (3HLL % KK   $$&HLL)h#3333V### "33 zz*...@AH~,,,  s ;EEc fddddddtjjddg}|j|| t j d }|d z d z }|j d d |dz jddtj|d5}t}d|_ d|_ ||j_|j||jj D cgc] } t#| } } t%d| DsJ dddycc} w#1swYyxYw)uQchain_complete 시 watchdog cron이 제거된다 (cokacdir --cron-remove 호출).r2rr3rz task-31.1r5Nr6rrrrTrz task-31.1.md완료.rMrNr`rrc3$K|]}d|v yw)z cron-removeNr)rcmds r$rzGTestNext.test_next_removes_watchdog_cron_on_complete..sC}+Cs)rrBrCrrbrcr rQrrdrrerfrgrhrcall_args_listrany) rnr#rr*r,rorrprqcall called_cmdss r$+test_next_removes_watchdog_cron_on_completez4TestNext.test_next_removes_watchdog_cron_on_completes17##&&lln668 $    *E2!!+6)I5 $6 ~ %11)g1N \\"l + Dx#+K%&K "!#K (3HLL % KK 2:1L1LM3t9MKMC{CC CC D DN D DsAD'0D"D'"D''D0ctjd}|j||j}t j |j }|ddk(sJ|ddk(sJy)uR어떤 체인에도 없는 task_id이면 action=no_chain을 반환한다 (exit 0).ztask-unknown-999rrno_chainr:N)rbrcrrrRrkrrnr#rr*rrorrs r$test_next_no_chainzTestNext.test_next_no_chainsf!!*<= D$$&HLL)h:---i $6666r&c ddddddtjjddd dd d dddddg}|j|| t j d }|dz dz }|j dd|dz jdd|j||j}tj|j} | ddk(sJd| dvsJy)ui이미 running/done 상태인 task의 task_file과 동일한 task_file을 가진 pending이 차단된다.r2zmemory/tasks/same-file.mdr3rz task-40.1r5Nr6rIr[r4rrrrTrz task-40.1.mdrrMrNrstalledzduplicate task_filereasonrrs r$%test_next_duplicate_task_file_blockedz.TestNext.test_next_duplicate_task_file_blockeds8##&&lln668 $ 8##" $  , *E2!!+6)I5 $6 ~ %11)g1N D$$&HLL)h9,,,$x(8888r&cv|j|tjd}|dz dz }|jdd|dz j dd |j ||d z }t j|jd }td |d D}|ddk(sJ|dJy)uLnext 호출 시 완료된 task의 status=done, completed_at이 설정된다.rrrrTrrrrMrNrc3JK|]}|jddk(s|ywrrrs r$rz8TestNext.test_next_marks_completed_at..s UqQUU95E5TUrr,r-doner=N) rrbrcr rQrrRrkrlr) rnr#rr*rorrrrD done_tasks r$test_next_marks_completed_atz%TestNext.test_next_marks_completed_ats *%!!+6)I5 $6 ~ %11)g1N D"33 zz*...@AUDMUU "f,,,(444r&c|j|tjd}|dz dz }|jdd|dz j dd |j ||j }tj|j}|d d k(sJ|j ||j }tj|j} | d d k(sJy)uW이미 done인 task에 대해 next를 다시 호출하면 already_done을 반환한다.rrrrTrrrrMrNrr already_doneNr) rnr#rr*rrorroutput1output2s r$"test_next_idempotency_already_donez+TestNext.test_next_idempotency_already_done#s *%!!+6)I5 $6 ~ %11)g1N D$$&**X\\*x J... D$$&**X\\*x N222r&cpddddddddd ddd ddg}|j|| tjd }|d z dz }|jdd|dz j dd|j ||j }tj|j} | ddk(sJy)u=다음 task가 이미 running이면 dispatch하지 않는다.r2zmemory/tasks/task-10.1.mdr3rrr5r7r8r9r-r:r;rIzmemory/tasks/task-10.2.mdz task-10.2rrrrTrrrrMrNralready_runningNrrs r$*test_next_idempotency_next_already_runningz3TestNext.test_next_idempotency_next_already_running8s 8##&  8##&   $ *E2!!+6)I5 $6 ~ %11)g1N D$$&HLL)h#4444r&c Z|dz dz dz }|jjdd|jddd d d d d dtjj dddd ddddg}|dz }ddtjj dddd|d}|jt j|dddtjd } |dz d z } | jdd| d!z jd"d|j| |dz dz d#z } | jsJd$| jd|jdk(sJ|j} t j| j} | d%d&k(sJ| d'dk(sJy())u>task_file이 없을 때 original_task_file에서 복사한다.rr,z task-20.mdTru-# 원본 지시서 Phase 1: ... Phase 2: ...rMrNr2zmemory/tasks/task-20.1.mdr3rrr5)r7r8r9r-r:r;r<rIzmemory/tasks/task-20.2.mdr4z task-20.2rr chain-testr>rarr^zmemory/tasks/task-20.md)r+r@rAr-r/r.original_task_filer,FrJrrrrz task-20.2.mdu6Phase 2 지시서 파일이 자동 생성되어야 함rrr8N)parentr rQrrBrCrRrSrbrcrrjrlrrkr)rnr#rr*rrr,rrrDrorphase2_task_filerrs r$1test_next_creates_missing_task_file_from_originalz:TestNext.test_next_creates_missing_task_file_from_originalZs&07:\I!!''t'D%%&Xcj%k 8##&&lln668 8##&   & "33 $",,.224";   djjE!LW^_!!+6)I5 $6 ~ %11)g1N D$h.8>I&&(b*bb( ))7);?Q?[?[el?[?mmmm$$&HLL)h:---k"&AAAAr&)rNra)rrrrrrrrrrrrrrrrrrrrrr&r$rrs. %!$ +++d{ +  +  +Z$&2:.$$.L%-ND@ 7$9L5"3* 5D<Br&rcDeZdZdZd dededefdZdZdZdZ d Z d Z y ) TestUpdateu&cmd_update() 서브커맨드 테스트r*r:r c dddd|ddddg}dd tjjd d d d |d}|dz }|jt j |ddd|S)u2update 테스트용 체인 파일을 생성한다.r2zmemory/tasks/task-x.mdr3r4r5Nr6zchain-update-testr>rau업데이트 테스트r^cron-001rchain-update-test.jsonFrIrJrMrNr)rnr*r:r,rDrs r$_setup_chain_with_taskz!TestUpdate._setup_chain_with_tasks5##"" $   ,",,.224- *  44  4eAFQXY r&c|j|tjdd}|j||dz }t j |j d}|dd}|d dk(sJ|d Jy ) u;running으로 상태 변경 시 started_at이 설정된다. task-50.1rr:r-rrMrNr,rr-r<Nrrbrc cmd_updaterRrkrlrnr#rr*rorrrDtasks r$test_update_to_runningz!TestUpdate.test_update_to_runnings ##J/!!+iH d":: zz*...@AG}QH~***L!---r&c|j|tjdd}|j||dz }t j |j d}|dd}|d dk(sJ|d Jy ) u:done으로 상태 변경 시 completed_at이 설정된다.rrrrrMrNr,rr-r=Nrrs r$test_update_to_donezTestUpdate.test_update_to_dones ##J/!!+fE d":: zz*...@AG}QH~'''N#///r&c|j|tjdd}|j||dz }t j |j d}|dd}|d dk(sJy ) u@failed로 상태 변경 시 status=failed로 업데이트된다.rfailedrrrMrNr,rr-Nrrs r$test_update_to_failedz TestUpdate.test_update_to_failedsu ##J/!!+hG d":: zz*...@AG}QH~)))r&c|j|tjdd}|j||dz }t j |j d}|dd}|d dk(sJy ) uBstalled로 상태 변경 시 status=stalled로 업데이트된다.rrrrrMrNr,rr-Nrrs r$test_update_to_stalledz!TestUpdate.test_update_to_stalledsu ##J/!!+iH d":: zz*...@AG}QH~***r&c|j|tjdd}tjt 5}|j |dddjjdk(sJy#1swY%xYw)uD존재하지 않는 task_id 업데이트 시 exit 1이 발생한다.ztask-nonexistentrrNr2) rrbrcrrrrrr)rnr#rr*rors r$ test_update_task_not_found_exitsz+TestUpdate.test_update_task_not_found_exitssj ##J/!!*rau정체 테스트r^rrrHFrIrJrMrN)rrBrrCrQrRrS)rnr*r+rr<r,rDrs r$_setup_chain_with_running_taskz/TestCheckStalled._setup_chain_with_running_tasksllny7H'IITTV ;##&( $   !",,.224' *  xj..  4eAFQXY r&c|j|dtjd}|j||j }t j |j}t|tsJt|dk(sJ|dddk(sJ|dd d k(sJ|dd d k(sJ|dd dk\sJy)u3max_hours 초과한 running 작업이 검출된다.@rrI max_hoursr2rr+chain-stalled-testr:r r9r[ hours_elapsedN r rbrccmd_check_stalledrrRrkr isinstancerrmrs r$"test_check_stalled_detects_stalledz3TestCheckStalled.test_check_stalled_detects_stalleds ++J#+N!!A. T"$$&HLL)&$'''6{aay$(<<<<ay#{222ay K///ay)Q...r&c|j|dtjd}|j||j }t j |j}t|tsJt|dk(sJy)u=max_hours 미만인 running 작업은 검출되지 않는다.g?rrIrrNrrs r$test_check_stalled_no_stalledz.TestCheckStalled.test_check_stalled_no_stalled-su ++J#+N!!A. T"$$&HLL)&$'''6{ar&ctjd}|j||j}t j |j }|gk(sJy)u6활성 체인이 없으면 빈 배열을 출력한다.rIrN)rbrcrrrRrkrrs r$test_check_stalled_empty_resultz0TestCheckStalled.test_check_stalled_empty_result8sL!!A. T"$$&HLL)||r&c tjtdz j}dddddd|d d g}d d tjjd dd|d}|dz }|j t j |dddtjd} |j| |j} t j| j} | gk(sJy )uEcompleted/stalled 체인의 task는 정체 검사에서 제외된다.r{r r2rYr3rz task-70.1r5Nr6zchain-completedr>ru 완료 체인r^r?zchain-completed.jsonFrIrJrMrNr) rrBrrCrQrRrSrbrcrrrkr) rnr#rr*rr<r,rDrrorrs r$)test_check_stalled_skips_completed_chainsz:TestCheckStalled.test_check_stalled_skips_completed_chainsAsllnyq'99DDF 1##&( $   *",,.224!$ 22  4eAFQXY!!A. T"$$&HLL)||r&N)rr) rrrrrrfloatr rrrrrr&r$rrsM7 -#&   !   D /   r&rc(eZdZdZdZdZdZdZy)TestListu$cmd_list() 서브커맨드 테스트ctj}|j||j}t j |j }|gk(sJy)u0체인이 없을 때 빈 배열을 출력한다.N)rbrccmd_listrrRrkrrs r$test_list_emptyzTestList.test_list_emptylsH!!# D$$&HLL)||r&c~tdD]"}td|dd|}t||$tj}|j ||j }tj|j} t| dk(sJ| D cgc]} | d } } d| vsJd| vsJd | vsJy cc} w) u:여러 체인이 있을 때 모두 목록에 포함된다.r~rG03du범위 )r+r/r+z chain-000z chain-001z chain-002N) rrErUrbrcr"rrRrkrrm) rnr#rr*rrrDrorritem chain_idss r$test_list_multiple_chainsz"TestList.test_list_multiple_chainsusq +A#vaW-=wqc]SD T * +!!# D$$&HLL)6{a289$T*%9 9i'''i'''i''':s B:c6td}t||tj}|j ||j }t j|j}t|dk(sJ|d} d| vsJd| vsJd| vsJd| vsJy ) uL목록의 각 항목에 chain_id, status, scope, tasks 수 필드가 있다.z chain-fields)r+r2rr+r-r/ task_countN) rErUrbrcr"rrRrkrrm) rnr#rr*rrDrorrr&s r$test_list_shows_required_fieldsz(TestList.test_list_shows_required_fieldss8Z&!!# D$$&HLL)6{aayT!!!4$t###r&c RtdDcgc]}|dzd|dddddddd }}td | }t||tj}|j ||j } tj| j} | d d dk(sJycc}w)u<task_count가 실제 tasks 배열의 길이와 일치한다.r2r|r}r3r4Nr5r6z chain-count)r+r,rr*) rrErUrbrcr"rrRrkr) rnr#rr*rrr,rDrorrs r$test_list_task_count_correctz%TestList.test_list_task_count_corrects1X  Q-aS4##" $      eDZ&!!# D$$&HLL)ay&!++++  sB$N)rrrrr#r(r+r.rr&r$r r is.("$",r&r ceZdZdZdZdZy)TestLocku@lock 파일을 이용한 원자적 상태 업데이트 테스트c Ldddddddddg}d d tjjd d d d|d}|dz }|jt j |dddt jdd}|j||dz }|jrJy)uL상태 업데이트 시 lock 파일이 생성되고 완료 후 삭제된다.r2zmemory/tasks/lock-test.mdr3r4z task-80.1r5Nr6zchain-lock-testr>rau 락 테스트r^rrzchain-lock-test.jsonFrIrJrMrNrrzchain-lock-test.lock rrBrCrQrRrSrbrcrrj) rnr#rr*r,rDrrro lock_files r$"test_lock_file_created_and_removedz+TestLock.test_lock_file_created_and_removeds8##&" $   *",,.224$ *   "88 djjE!LW^_!!+iH d!77 ##%%%%r&c tdDcgc]}|dzd|ddddd|zd d d d d }}d dtjjdddd|d}|dz }|j t j |dddtdD]1}tjdd|zd d}|j|3t j|jd} | dD] } | ddk(r Jy cc}w)u6순차 업데이트 시 최종 상태가 정확하다.r~r2r|r}r3r4ztask-Zz.1r5Nr6zchain-seq-testr>rau순차 테스트r^rrzchain-seq-test.jsonFrIrJrMrNrrr,r-) rrrBrCrQrRrSrbrcrrkrl) rnr#rr*rr,rDrrro final_datars r$#test_sequential_updates_consistencyz,TestLock.test_sequential_updates_consistencysC1X  Q-aS4##"26("-" $     )",,.224' *   "77 djjE!LW^_q A%%b1fXR.@PD MM$  ZZ 4 4g 4 FG w' ,D>V+ ++ ,A  s DN)rrrrr4r8rr&r$r0r0sJ &D#,r&r0c"eZdZdZdZdZdZy) TestBackupu*체인 파일 .bak 백업 기능 테스트c Ldddddddddg}d d tjjd d d d|d}|dz }|jt j |dddt jdd}|j||dz }|jsJy)u-.bak 파일이 update 직전에 생성된다.r2zmemory/tasks/bak-test.mdr3r4 task-100.1r5Nr6zchain-bak-testr>rau백업 테스트r^rrzchain-bak-test.jsonFrIrJrMrNrrzchain-bak-test.json.bakr2) rnr#rr*r,rDrrrobak_files r$test_backup_created_on_updatez(TestBackup.test_backup_created_on_update s7##'" $   )",,.224' *   "77 djjE!LW^_!!,yI d 99   r&c dddddddddg}d d tjjd d d d|d}|dz }tj|dd}|j |dt jdd}|j||dz } tj| jd} | ddddk(sJy)uA.bak 파일에 업데이트 전 원본 데이터가 저장된다.r2z memory/tasks/bak-content-test.mdr3r4z task-101.1r5Nr6zchain-bak-contentr>rau백업 내용 테스트r^rrzchain-bak-content.jsonFrIrJrMrNrrzchain-bak-content.json.bakr,rr-) rrBrCrRrSrQrbrcrrkrl) rnr#rr*r,rDrr original_textror=bak_datas r$"test_backup_contains_original_dataz-TestBackup.test_backup_contains_original_data*s?##'" $   ,",,.224. *   "::  4eAF mg>!!,yI d <<::h00'0BC #H-:::r&c ddddddtjjddg}d d tjjd d d d|d}|dz }|jt j |ddd|dz dz }|j dd|dz jddtj|d5}t} d| _ d| _ | |j_ tjd} |j!| ddd|d z } | j#sJy#1swY!xYw)!u6cmd_next 호출 시에도 .bak 파일이 생성된다.r2zmemory/tasks/bak-next-test.mdr3rz task-102.1r5Nr6zchain-bak-nextr>raunext 백업 테스트r^rrzchain-bak-next.jsonFrIrJrMrNrrTrz task-102.1.mdrr`rrrzchain-bak-next.json.bak)rrBrCrQrRrSr rrdrrerfrgrhrbrcrrj) rnr#rr*r,rDrrrrprqror=s r$test_backup_created_on_nextz&TestBackup.test_backup_created_on_nextNsP<##'&lln668 $   )",,.224, *   "77 djjE!LW^_)I5 $6  &229w2O \\"l + x#+K%&K "!#K (3HLL %%%l;D KK    99     s AD>>EN)rrrrr>rBrDrr&r$r:r:s4!B";H(!r&r:c^eZdZdZdedededefdZdZdZ d Z d Z d Z d Z d ZdZdZy) TestChecku5cmd_check() 서브커맨드 테스트 (읽기 전용)r*r+r,r c |dtjjdddd|d}|d|dz }|jt j |d d d |S)u+테스트용 체인 파일을 생성한다.r>raucheck 테스트r^rrrGrHFrIrJrMrNr)rnr*r+r,rDrs r$rzTestCheck._setup_chainsj!",,.224& *  fXJe44  4eAFQXY r&c ddddddtjjddd d d d d ddddg}|j|d|t j d}|j ||j}tj|j}|ddusJ|ddusJ|ddk(sJ|dd k(sJy)ub체인 소속이고 마지막이 아닌 경우: in_chain=true, is_last=false, next_task_id 반환.r2memory/tasks/dispatch-436.2.mdr3r task-436.2r5Nr6rIzmemory/tasks/dispatch-436.3.mdr[r4z task-436.3zremotion-migrationrin_chainTis_lastFr+ next_task_id rrBrCrrbrc cmd_checkrrRrkr rnr#rr*rr,rorrs r$test_check_in_chain_not_lastz&TestCheck.test_check_in_chain_not_lasts=##'&lln668 $ =##'" $  , *&:EB!!,7 T$$&HLL)j!T)))i E)))j!%9999n%555r&c ddddddtjjtjjddd d d d dtjjd dg}|j|d|t j d }|j ||j}tj|j}|ddusJ|ddusJ|ddk(sJ|dJy )uX체인 소속이고 마지막인 경우: in_chain=true, is_last=true, next_task_id=null.r2zmemory/tasks/dispatch-436.1.mdr3rz task-436.1r5r6rIrIr[rrJNzremotion-migration-lastrrKTrLr+rMrNrPs r$test_check_in_chain_is_lastz%TestCheck.test_check_in_chain_is_lasts=# '&lln668 (  8 8 : =##'&lln668 $  , *&?G!!,7 T$$&HLL)j!T)))i D(((j!%>>>>n%---r&ctjd}|j||j}t j |j }|ddusJ|ddusJ|dJ|dJy) uU어떤 체인에도 없는 task_id: in_chain=false, chain_id=null, next_task_id=null.ztask-nonexistent-9999rrKFrLr+NrM)rbrcrOrrRrkrrs r$test_check_not_in_chainz!TestCheck.test_check_not_in_chains!!*AB T$$&HLL)j!U***i E)))j!)))n%---r&c ddddddtjjddd d d d dddddg}|j|d |t j d}|j ||j}tj|j}|ddusJ|ddusJ|dd k(sJ|dJy)uN다음 task가 pending이고 task_id=None인 경우: next_task_id=null 반환.r2zmemory/tasks/dispatch-500.1.mdr3rz task-500.1r5Nr6rIzmemory/tasks/dispatch-500.2.mdr[r4zpending-no-id-chainrrKTrLFr+rMrNrPs r$)test_check_next_task_id_none_when_pendingz3TestCheck.test_check_next_task_id_none_when_pendings=##'&lln668 $ =##" $  , *&;UC!!,7 T$$&HLL)j!T)))i E)))j!%::::n%---r&cddddddddd dg}tjd tj|d d d }t j |d5}t }d|_d|_||j_ |j|ddd|dz }tj|jd} | ddddk(sJ| ddddk(sJy#1swYTxYw)uBcreate 시 tasks JSON의 task_id가 체인 파일에 보존된다.r<r2zmemory/tasks/test.mdr3r:r7r8r9z task-100.2rIzmemory/tasks/test2.mdr[zpreserve-id-testutask_id 보존 테스트r>r^r_r`rz{"cron_id": "cron-preserve"}Nzchain-preserve-id-test.jsonrMrNr,r:)rbrcrRrSrrdrrerfrgrhrirkrlrxs r$test_create_preserves_task_idz'TestCheck.test_create_preserves_task_ids%q?U_j k$q?V`k l !!'**U#,  \\"l + x#+K%&K "!?K (3HLL % MM$    "?? zz*...@AG}Q *l:::G}Q *l:::  s ;C  C)c\ddddddddd dg}tjd tj|d d d }t j |d5}t }d|_d|_||j_ |j|ddd|jtjd} |j| |j} tj| j} | ddusJ| ddusJ| dd k(sJ| ddk(sJy#1swYxYw)uIcreate로 생성한 체인에서 task_id로 check 매칭이 성공한다.z task-200.1r2zmemory/tasks/t200-1.mdr3rYz task-200.2rIzmemory/tasks/t200-2.mdr[zcheck-find-testucheck 매칭 테스트r>r^r_r`rz{"cron_id": "cron-find"}NrrKTrLFr+rM)rbrcrRrSrrdrrerfrgrhrirrOrkr) rnr#rr*rr, args_createrprq args_checkrrs r$!test_check_finds_chain_by_task_idz+TestCheck.test_check_finds_chain_by_task_id s>%q?Wal m$q?Wal m ((&**U#*  \\"l + 'x#+K%&K "!;K (3HLL % MM+ &  ' '' =  Z $$&HLL)j!T)))i E)))j!%6666n%555# ' 's ;D""D+c ddddddtjjddd d dd d ddddg}|j|d |t j d}|dz dz }|j dd|dz jdd|j||j}tj|j} | ddk(sJd| vsJd| dd k(sJy)uEcmd_next의 dispatch action 출력에 task_id 필드가 포함된다.r2zmemory/tasks/task-566.1.mdr3rz task-566.1r5Nr6rIzmemory/tasks/task-566.2.mdr4z task-566.2zchain-566-testrrrTrz task-566.1.mdrrMrNrrr:u2dispatch action 출력에 task_id 필드가 없음rrs r$$test_next_includes_task_id_in_outputz.TestCheck.test_next_includes_task_id_in_outputAs9##'&lln668 $ 9##'" $  , *&6>!!,7)I5 $6  &223Cg2V D$$&HLL)h:---F"X$XX"i L000r&c ddddddtjjddd d dd dddddg}|j|d |t j d }|dz dz }|j dd|dz jdd|j||j}tj|j} | ddk(sJd| vsJ| dJy)uW다음 pending task의 task_id가 None이면 출력의 task_id도 None이어야 한다.r2zmemory/tasks/task-567.1.mdr3rz task-567.1r5Nr6rIzmemory/tasks/task-567.2.mdr4zchain-567-testrrrTrz task-567.1.mdrrMrNrrr:rrs r$-test_next_task_id_none_when_pending_has_no_idz7TestCheck.test_next_task_id_none_when_pending_has_no_idis9##'&lln668 $ 9##" $  , *&6>!!,7)I5 $6  &223Cg2V D$$&HLL)h:---F"""i (((r&cddddddddd dg}tjd tj|d d d }t j |d5}t }d|_d|_||j_ |j|dddtjdd} |j| |j|dz dz } | jdd| dz jddtjd} |j!| |j} tj"| j$} | ddk(sJ| d dk(sJ| d!d k(sJ|d"z }tj"|j'd}t)d#|d$D}|d%d&k(sJ|d'Jy#1swY8xYw)(uHcreate로 생성한 체인에서 task_id로 next 진행이 성공한다. task-300.1r2zmemory/tasks/t300-1.mdr3rYz task-300.2rIzmemory/tasks/t300-2.mdr[znext-advance-testunext 진행 테스트r>r^r_r`rz{"cron_id": "cron-advance"}NrrrrTrz task-300.1.mdrrMrNrrrr8r9zchain-next-advance-test.jsonc3JK|]}|jddk(s|yw)r:rdNrrs r$rz:TestCheck.test_next_advances_by_task_id..s VqQUU95E5UVrr,r-rr=)rbrcrRrSrrdrrerfrgrhrirrr rQrrkrrlr)rnr#rr*rr,r\rprq args_updater args_nextrrrrrDrs r$test_next_advances_by_task_idz'TestCheck.test_next_advances_by_task_ids%q?Wal m$q?Wal m (((**U#)  \\"l + 'x#+K%&K "!>K (3HLL % MM+ &  '((iP  k")I5 $6  &223Cg2V&&|<  I$$&HLL)h:---k"&>>>>f~,,, "@@ zz*...@AVDMVV "f,,,(444C ' 's ;GG N)rrrrrrrrrQrSrUrWrZr^r`rbrhrr&r$rFrF~sY?ts4D !6F!.F .!.F;46B&1P%)N/5r&rFc heZdZdZ ddedededededef dZd Zd Z d Z d Z d Z dZ dZdZy)TestF12RetryPhaseu-F12: completion-promise retry phase 테스트r*rr:rreport_contentr c dddd|dtjjd|d dd dd d dddd g}d dtjjdddd|d}|dz }|jt j |ddd|dz dz } | j dd| |dz j|d|S)u;F12 테스트용 체인 + 보고서를 생성하는 헬퍼.r2zmemory/tasks/task-f12-1.mdr[rr5N r7r8r9r-r:r;r<r=rrIzmemory/tasks/task-f12-2.mdr4 task-f12.2r6chain-f12-testr>rauF12 retry 테스트r^zcron-f12rchain-f12-test.jsonFrJrMrNrrTrr})rrBrCrQrRrSr ) rnr*rr:rrkr,rDrrs r$_setup_chain_with_retryz)TestF12RetryPhase._setup_chain_with_retrys9##"&lln668 $* 9##'" $  0)",,.224* *  11  4eAFQXY)I5 $6 '# &22>G2T r&c|j||dtjd}|j||j }t j |j}|ddk(sJ|ddk(sJt j |d z jd }|d d k(sJtd|dD} | d dk(sJ| ddk(sJy)uKretry_count=0인 상태에서 QC FAIL → action=dispatch, retry_attempt=1.rr task-f12.1rrrrr2rprMrNr-rac3JK|]}|jddk(s|ywr:rtNrrs r$rzCTestF12RetryPhase.test_f12_first_qc_fail_retries.. XquuY7G<7W1Xrr,rrN rqrbrcrrrRrkrrlr rnr#rr*rrorrrDrs r$test_f12_first_qc_fail_retriesz0TestF12RetryPhase.test_f12_first_qc_fail_retriess $$Zq$I!!,7 D$$&HLL)h:---o&!+++zz:(==HHRYHZ[H~)))Xd7mXX 8$ 111=)Q...r&c|j||dtjd}|j||j }t j |j}|ddk(sJ|ddk(sJt j |d z jd }|d d k(sJtd|dD} | ddk(sJy)uKretry_count=1인 상태에서 QC FAIL → action=dispatch, retry_attempt=2.r2rsrtrrrrrIrprMrNr-rac3JK|]}|jddk(s|ywrvrrs r$rzDTestF12RetryPhase.test_f12_second_qc_fail_retries..#rwrr,rNrxrys r$test_f12_second_qc_fail_retriesz1TestF12RetryPhase.test_f12_second_qc_fail_retriess $$Zq$I!!,7 D$$&HLL)h:---o&!+++zz:(==HHRYHZ[H~)))Xd7mXX =)Q...r&c|j||dtjd}|j||j }t j |j}|ddk(sJd|dvsJd |vsJt j |d z jd }|d dk(sJ|dz dz dz } | js Jd| y)uMretry_count=2(=MAX_RETRY)인 상태에서 QC FAIL → circuit breaker 발동.rIrsrtrrrcircuit_breakerrescalation_filerprMrNr-r escalationstask-f12.1_escalation.jsonu*escalation 파일이 생성되어야 함: N) rqrbrcrrrRrkrrlrj) rnr#rr*rrorrrDrs r$%test_f12_circuit_breaker_on_max_retryz7TestF12RetryPhase.test_f12_circuit_breaker_on_max_retry&s $$Zq$I!!,7 D$$&HLL)h9,,, F8$4444 F***zz:(==HHRYHZ[H~***#X- =@\\%%'g+UVeUf)gg'r&c|j||dtjd}|j||j |dz dz dz }|j sJt j|jd }d |vsJd |vsJd |vsJd |vsJd|vsJd|vsJd|vsJ|d dk(sJ|d dk(sJ|ddk(sJy)u;circuit breaker 발동 후 escalation 파일 내용 검증.rIrsrtrrrrrMrNr:r+ triggered_atr max_retrytotal_attemptsrroN) rqrbrcrrrjrRrkrl)rnr#rr*rrorcontents r$ test_f12_escalation_file_contentz2TestF12RetryPhase.test_f12_escalation_file_content;s $$Zq$I!!,7 D"X- =@\\%%'''**_666HIG###W$$$(((7"""g%%%7***7"""y!\111z"&6666{#q(((r&c&|jdk(sJy)uMAX_RETRY == 2 확인.rIN) MAX_RETRY)rnr#rr*s r$ test_f12_max_retry_constant_is_2z2TestF12RetryPhase.test_f12_max_retry_constant_is_2Ts||q   r&c|j||ddtjd}|j||j }t j |j}|ddk(sJ|dd k(sJd |vsJy ) uRretry_count=1인 상태에서 QC PASS → action=dispatch (다음 task로 진행).r2u'작업 완료. 모든 테스트 통과.)rrkrtrrrr:rnrN)rqrbrcrrrRrkrrs r$ test_f12_qc_pass_no_retry_neededz2TestF12RetryPhase.test_f12_qc_pass_no_retry_neededXs $$  D % !!,7 D$$&HLL)h:---i L000f,,,r&c|j||dtjd}tjj }|j ||jtj|dz jd}td|d D}|d d k(sJ|d J|dJ|d|k\sJy )uUretry 후 target_task의 status=running, completed_at=None, started_at 갱신 확인.rrsrtrrprMrNc3JK|]}|jddk(s|ywrvrrs r$rzFTestF12RetryPhase.test_f12_retry_resets_task_status..urwrr,r-rr=Nr<) rqrbrcrrBrCrrrRrkrlr) rnr#rr*rrobeforerDrs r$!test_f12_retry_resets_task_statusz3TestF12RetryPhase.test_f12_retry_resets_task_statusks $$Zq$I!!,7))+ Dzz:(==HHRYHZ[Xd7mXX 8$ 111>*222<(444<(F222r&c fddddddtjjddd d d dd d ddddg}ddtjjdddd|d}|dz }|jt j |dd d|dz dz }|j dd|dz jd dtjd!} |j| |j} t j| j} | d"d#k(sJ| d$d k(sJd%| vsJy)&uIgate=none인 task는 QC FAIL이어도 retry 없이 다음 task로 진행.r2z"memory/tasks/task-f12-gate-none.mdr[rztask-f12-gate.1r\NrrmrIz$memory/tasks/task-f12-gate-none-2.mdr4ztask-f12-gate.2r6zchain-f12-gate-noner>raugate=none 테스트r^z cron-f12-gaterzchain-f12-gate-none.jsonFrJrMrNrrTrztask-f12-gate.1.mduQC FAIL: 오류 발견.rrrr:r) rrBrCrQrRrSr rbrcrrrkr) rnr#rr*rr,rDrrrrorrs r$!test_f12_gate_none_bypasses_retryz3TestF12RetryPhase.test_f12_gate_none_bypasses_retry}shA##,&lln668 $  C##," $  0.",,.224* /   "<< djjE!LW^_)I5 $6 + +778Q\c7d!!*;< D$$&HLL)h:---i $5555f,,,r&N)rtruQC FAIL: 타입 에러 발견.)rrrrrrintrqrzr}rrrrrrrr&r$rjrjsy7 $> 111 1  1  1 1f/*/(h*)2!-&3$3-r&rjc"eZdZdZdZdZdZy)TestCircuitBreakerIntegrationu6circuit_breaker 모듈 통합 테스트 (task-1651.1).ct|}|dz dz }|jddd|dz }|jsJdtj|j }|ddk(sJ|d dk(sJ|d d k(sJd |d vsJy)ug_trigger_circuit_breaker가 circuit_breaker 모듈의 _write_escalation_file을 호출하는지 검증.rrz task-test-1z chain-test-1r~ztask-test-1_escalation.jsonu+escalation 파일이 생성되어야 한다r:r+r escalationrrN)r%_trigger_circuit_breakerrjrRrkrl)rnrr#escalations_dirrrDs r$(test_trigger_uses_circuit_breaker_modulezFTestCircuitBreakerIntegration.test_trigger_uses_circuit_breaker_modules  *"X- = ##M>1E),II%%'V)VV'zz/3356I-///J>111H~---d8n,,,r&cjt|}|dz dz }t|dd}t|dd |jdddt|d||dz }|j sJd t j |j}|d dk(sJ|d dk(sJy #t|d|wxYw) u`circuit_breaker 모듈 미사용 시 fallback으로 escalation 파일이 생성되는지 검증.rr _CB_AVAILABLEFztask-fallback-1z chain-fb-1r~ztask-fallback-1_escalation.jsonu:fallback으로 escalation 파일이 생성되어야 한다r:r+N)r%getattrsetattrrrjrRrkrl)rnrr#r original_cbrrDs r$)test_trigger_fallback_when_cb_unavailablezGTestCircuitBreakerIntegration.test_trigger_fallback_when_cb_unavailables  *"X- =b/59 OU+ 6  ' '(9< K B 5),MM%%'e)ee'zz/3356I"3333J</// B 5s B##B2cddl}ddlm}|j||j}|dz |_ |j ddddd ||_t |dz jd }t|d k(sJtj|dj}|d dk(sJ|d dk(sJ|ddk(sJ|ddk(sJy#||_wxYw)uN_write_escalation_file이 **extra 필드를 payload에 포함하는지 검증.rNr test_extraz test reasonr~z chain-extra custom_value)contextr error_countr+ custom_fieldz*_escalation.jsonr2r+rrr) importlibutils.circuit_breakerrreloadESCALATIONS_DIR_write_escalation_filerglobrmrRrkrl)rnrrcb_mod original_dirfilesrDs r$'test_write_escalation_file_extra_fieldszETestCircuitBreakerIntegration.test_write_escalation_file_extra_fieldss. -- !)M!9 2  ) )$$&+ * &2F "h.445HIJ5zQzz%(,,./J=000N#~555I,...M"a'''&2F "s C CN)rrrrrrrrr&r$rrs@ -0&(r&r)z test-chainNrar^r]r)#rrbrRrrtypesrrpathlibr unittest.mockrrr ModuleTyper%fixturer#r*rrrdictrErUrWrrrr r0r:rFrjrrr&r$rs{  (* $5+;+;8))   !##- !! $;! ! !  ! Dj ! !H T  $ $u(u(zTBTBx S(S(vhh`E,E,ZH,H,`p!p!pA5A5R i-i-b@(@(r&