(Q   )  "" "rct|ddddddddddtt|}|jd}|ddusJ|d d k(sJ|dd k(sJd |d vsJy)u7일부 running이면 complete=False, pending에 포함.r&r'r=runningr>r0r?Fr@rAr2r/rBNrCrEs r2test_batch_watchdog_check_batch_completion_partialrIns#,?#,?#, B CM:H  , ,Y 7F *  && & '?a   &>Q   vi( (( (rcHtjtjt dz j }t |ddd|ditt|}|jdd }t|d k(sJ|d d dk(sJ|d d dkDsJy)uDstart_time이 2시간 이상인 running task를 감지해야 한다.rA)hoursztask-oldr&rH)r*r+ start_timer0g@) ttl_hoursrr) elapsed_hoursN) rnowrutcr isoformatr"rr4 check_ttlr6)r three_hours_agor7stales r%test_batch_watchdog_check_ttl_expiredrVs ||HLL1IA4FFQQSO %#-  CM:H   yC  8E u:?? 8I * ,, , 8O $s ** *rc t|}|dz jtjddddd|dz jtjd dddd|d z jtjd d dddt |ddd ddd d dd d dd dt t |}tj|d5|j}ddddvsJd |vsJy#1swYxYw)u.전팀 완료 batch_id만 반환해야 한다.z task-a1.donetask-a1r&r'r(rrz task-a2.donetask-a2z task-b1.donetask-b1batch-Br=rH)rXrYrZztask-b2r0send_ttl_warningN) rrrr r"rr4robjectrun)r rr7 completeds r1test_batch_watchdog_run_returns_completed_batchesr`s+ h 'F n(( yi6RS) n(( yi6RS)  n(( yi6RS) $-@$-@$-@$-C  CM:H h 2 3#LLN #  !! ! I %% % ##s DD c t|}|dz jtjddddddd |d z jtjd ddd ddd |d z jtjdddddd t t |}|j d}t|dk(sJ|Dchc]}|d }}|dd hk(sJycc}w)uEbatch_id에 해당하는 task의 merge_branch를 수집해야 한다.r$r%r&r'ztask/task-1-dev1z /some/project)r)r*r+ merge_branch project_pathrrr,r-ztask/task-2-dev2r.r/r[ztask/task-3-dev3)r)r*r+rbr0r2branchN)rrrr r r4find_merge_branchesr6)r r preflightbranchesb branch_namess r"test_preflight_find_merge_branchesrjs' h 'F m'' #% 2 /   (  m'' #% 2 /   (  m'' #% 2   ( c(m&QNN&CIdRVWNN. I c(mxYw#1swYBxYw#1swYFxYw#1swYJxYw#1swYNxYw)u~3팀 완료 → L1 감지 → L2 충돌 없음 → L3 PASS 검증. 이것이 task 지시서의 핵심 검증 시나리오.)dev1dev2dev3rNztask-z.donez batch-piper')r)r*r+team_idrrr=r>rrTrztest_pipeline_pass.pyz(def test_pipeline_ok(): assert True r0r\send_conflict_alert send_resultre) return_valuerz1 passedg?)rrdurationrNbatches_checkedr)r enumeraterrr r"rr r4rr]r7rf test_runnerr^)r rteamsiteam int_test_dirgater8s r&test_graduated_auto_gate_full_pipeliners h 'F $EUA&  4 E!E" ".. JJ!&qc{ ,$#   /   #/6B#/6B#/6B g% 5Ltd3++7748 CM :D  T]]$67 T^^%:;  T%%}5  NN !      $  ,-0 # $ )) ) ( q  3sl!G#9!G#G =(F? %F3 6F? >G GG#3F<8F? ?G G  G GG G##G,)!__doc__rrsysrrrpathlibr unittest.mockrpathinsertscripts.auto_mergerr r r rdictr"r;rFrIrVr`rjrrrrrrrrrs   22() t  4!,H#()(+0%&Z.Db>%BN3lE" %8B!r