+j?< LdZddlmZddlZddlmcmZddl m Z ddl Z ddl Z ddlZddlmZe j"j%e j"j%e j"j%e j"j'eZee j"vre j"j-deeedz dz Ze j0j3dZeeeddxsdeek7ree j0Dcgc]}|dk(s|j=d s|c}D]Ze j0e=e j@deeeedz g Z!gZ"dZ#e!e#uZ$e$Z%e$re!jLZ'dZ(e'e(uZ)e)Z%e%sBejTd e$fd e!e#fd ejVvsejXe!rejZe!nd ejZe#dzZ.dde.izZ/e"jae/e$rejTd e)fde'e(fd ejVvsejXe!rejZe!nd ejZe'ejZe(dzZ1dde1izZ2e"jae2ejfe"dizZ4dde4izZ5e6ejne5dxZ%xZ"xZ$xZ#xZ'xZ)Z(e jpe!Z9e9e j0d<e!jLjue9e j"jweddZd*dZ?dZ@dZAd ZBd!ZCd"ZDd#ZEd$ZFd%ZGd+d&ZHd'ZId(ZJd)ZKycc}w),u5task-2729+12 회귀 테스트 — B안 CODE/DATA 분리 + legacy NOOP 검증. 아르고스(QA) 작성. 검증 범위: A. CODE/DATA 분리: entrypoint.sh / anu-pickup.service / anu-pickup.path 파일 파싱. B. legacy NOOP 회귀: isolated temp DATA root 를 사용하여 driver scan_once 동작 검증. ) annotationsN)Pathdispatchz __init__.py__file__z dispatch.)submodule_search_locations)is not)z%(py2)s is not %(py5)s_spec)py2py5z%(py7)spy7)z5%(py11)s {%(py11)s = %(py9)s.loader } is not %(py14)s)py9py11py14z%(py16)spy16zassert %(py19)spy19scriptszanu_pickup_entrypoint.shdeploysystemdzanu-pickup.servicezanu-pickup.pathcjt|dd5}|jcdddS#1swYyxYw)Nrutf-8encoding)openread)pathfhs Y/home/jay/workspace/tests/regression/test_canonical_execution_path_alignment_b_2729p12.py_readr 7s. dC' *bwwys)2ctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d }||v}|stjd |fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d}||v}|stjd |fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}y )uLentrypoint.sh 가 cd 와 PYTHONPATH 를 CODE_ROOT 기반으로 사용한다.zcd "${CODE_ROOT}"inz%(py1)s in %(py3)scontentpy1py3u6entrypoint.sh 에 `cd "${CODE_ROOT}"` 가 없습니다 >assert %(py5)sr NzPYTHONPATH="${CODE_ROOT}"u>entrypoint.sh 에 `PYTHONPATH="${CODE_ROOT}"` 가 없습니다zcd "${WORKSPACE}"not inz%(py1)s not in %(py3)suYentrypoint.sh 에 `cd "${WORKSPACE}"` 가 남아 있습니다 — CODE/DATA 분리 위반zPYTHONPATH="${WORKSPACE}"uaentrypoint.sh 에 `PYTHONPATH="${WORKSPACE}"` 가 남아 있습니다 — CODE/DATA 분리 위반 r _ENTRYPOINT_SH @pytest_ar_call_reprcompare _saferepr @py_builtinslocals_should_repr_global_name_format_assertmsgAssertionError_format_explanationr% @py_assert0 @py_assert2 @py_format4 @py_format6s r,test_entrypoint_cd_pythonpath_uses_code_rootr=<sN#G  ' ) ' #*#* C ' &' 1 &' '+2+2 K  g - g '.'. f ' &g 5 &g '/6/6 nctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d }||v}|stjd |fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d}||v}|stjd |fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}y )uaentrypoint.sh 의 FLAG_FILE 과 LOCK_DIR 은 ${WORKSPACE}(canonical DATA) 기반이어야 한다.zFLAG_FILE="${WORKSPACE}/r"r$r%r&u1FLAG_FILE 이 ${WORKSPACE} 기반이 아닙니다r)r NzLOCK_DIR="${WORKSPACE}/u9LOCK_DIR fallback 이 ${WORKSPACE} 기반이 아닙니다zFLAG_FILE="${CODE_ROOT}r*r,uTFLAG_FILE 이 CODE_ROOT 기반으로 변경되었습니다 — DATA canonical 위반zLOCK_DIR="${CODE_ROOT}uSLOCK_DIR 이 CODE_ROOT 기반으로 변경되었습니다 — DATA canonical 위반r-r8s r(test_entrypoint_flag_lock_stay_canonicalr@QsN#G & % 0 % &*1*1 < % $ / $ %)0)0 D % $G 3 $G %-4-4 _ $ #7 2 #7 $,3,3 ^r>ctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}y ) u@CODE_ROOT 기본값이 ${HOME}/p0b-pickup-main 을 참조한다.z8CODE_ROOT="${PICKUP_CODE_ROOT:-${HOME}/p0b-pickup-main}"r"r$r%r&u>CODE_ROOT 기본값 라인이 없거나 형식이 다릅니다r)r Nr-r8s r!test_entrypoint_code_root_defaultrBhsN#G E E P E FJQJQ Ir>ctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}y )uhCODE_ROOT 부재 또는 driver 파일 누락 시 fail-closed 블록이 존재한다 (git 의존 제거).z! -d "${CODE_ROOT}"r"r$r%r&u]entrypoint.sh 에 CODE_ROOT 디렉토리 부재 조건 `! -d "${CODE_ROOT}"` 이 없습니다r)r Nz*${CODE_ROOT}/dispatch/anu_pickup_driver.pyudentrypoint.sh 에 driver 파일 체크 `${CODE_ROOT}/dispatch/anu_pickup_driver.py` 가 없습니다zexit 0u=entrypoint.sh 에 fail-closed exit 0 (no-op) 이 없습니다zgit -Cr*r,uaentrypoint.sh 에 `git -C` 가 남아 있습니다 — git 의존이 제거되지 않았습니다r-r8s r%test_entrypoint_code_root_fail_closedrDqs~N#G ! G + G !%,%, j 8 77 B 77 8ctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d }||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}y )uFanu-pickup.service 가 CODE_ROOT(%h/p0b-pickup-main) 를 참조한다.z#WorkingDirectory=%h/p0b-pickup-mainr"r$r%r&uKanu-pickup.service WorkingDirectory 가 %h/p0b-pickup-main 이 아닙니다r)r Nz)Environment=PYTHONPATH=%h/p0b-pickup-mainuQanu-pickup.service Environment PYTHONPATH 가 %h/p0b-pickup-main 이 아닙니다z%h/p0b-pickup-main/scripts/uZanu-pickup.service ExecStart 이 %h/p0b-pickup-main/scripts/ 를 참조하지 않습니다) r _SERVICE_FILEr/r0r1r2r3r4r5r6r7r8s r test_service_points_to_code_rootrGsM"G 0 0G ; 0G 15<5< V 7 6' A 6' 7;B;B \ ) (G 3 (G )-4-4 er>ctt}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}d }||v}|stjd |fd ||ftj|dt j vstj|rtj|nddz}tjd dzd|iz}ttj|d x}}d}||v}|stjd |fd ||ftj|dt j vstj|rtj|nddz}tjddzd|iz}ttj|d x}}y )utask-2733: anu-pickup.path 는 전용 inbox(%h/workspace/memory/events/p0b_inbox/ task-*.result.json)만 watch 한다. memory/events 직속 legacy 를 watch 하면 잔존 result.json 다수 매칭→start-limit-hit 폭주가 재발하므로, inbox 전용 glob 만 허용한다.zFPathExistsGlob=%h/workspace/memory/events/p0b_inbox/task-*.result.jsonr"r$r%r&uDanu-pickup.path 가 전용 inbox 경로를 watch 하지 않습니다r)r Nz7> _r>cx|dz dz dz }|jdd|dz dz }|jdd|S)utmp_path 에 inbox(memory/events/p0b_inbox) 와 memory/state 구조를 생성하고 scan 대상 디렉토리(inbox)를 반환. task-2733: driver scan/watch 대상은 전용 inbox 이다.memoryevents p0b_inboxTparentsexist_okstate)mkdir)tmp_path events_dir state_dirs r_make_events_dirrWsPH$x/+=JTD18#g-I OOD4O0 r>cz|dz dz dz }|jjdd|jddy ) u5memory/state/p0b_driver_enabled 에 'enabled' 기록.rLrRp0b_driver_enabledTrOzenabled rrN)parentrS write_text)rTflags r_enable_driverr]s> h  (+? ?DKKdT2OOK'O2r>c|gd}g}tjdz }|D]U}||z }|jddtjt |||f|j t |W|S)uVtask-*.result.json 파일들을 과거 mtime 으로 생성하고 경로 목록 반환.)ztask-A.result.jsonztask-B.result.jsonztask-C.result.jsonztask-D.result.jsonQ{}rr)timer[osutimestrappend)rUnamespaths past_timenameps r_create_task_filesrks| }  E e#I   TG , Q)Y/0 SV  Lr>c ddlm}m}m}t |}t |t |}ttjt|}t|}t|}||k(} | stjd| fd||fdtjvstj trtj"tnddtjvstj |rtj"|ndtj"|dtjvstj trtj"tnddtjvstj |rtj"|ndtj"|dz} tj$d d zd | iz} t'tj(| d x}x} }t+j*d z} |t|d| d ddd} ttjt|}| Dcgc]}|j,s|}}t|}t|}||k\} | stjd| fd||fdtjvstj trtj"tnddtjvstj |rtj"|ndtj"|dtjvstj trtj"tnddtjvstj |rtj"|ndtj"|dz} tj$dt|dt|dd zd | iz} t'tj(| d x}x} }|D]}|j.}||k(}|s tjd|fd||fdtjvstj |rtj"|ndtj"|dtjvstj |rtj"|nddz}tj$|j,d|j.ddzd |iz}t'tj(|d x}}|j0}d} || u}|stjd!|fd"|| fdtjvstj |rtj"|ndtj"|tj"| d#z}tj$|j,d$d%zd&|iz}t'tj(|d x}x}} ||k(}|stjd|fd'||fdtjvstj |rtj"|ndd(tjvstj |rtj"|nd(d)z}tj$d*t3|d+t3|d,zd-|iz}t'tj(|d }||j5d.tj6z }|j9rDt;|j=}t|}d}||k(} | stjd| fd/||fdtjvstj trtj"tndd0tjvstj |rtj"|nd0tj"|tj"|d1z}tj$d2|d3zd4|iz} t'tj(| d x}x} }y y cc}w)5ulegacy_cutoff=True + 미래 activation_epoch → 모든 task-* 파일이 NOOP_LEGACY_SKIP. 파일 이동/삭제 0, quarantine 디렉토리 미생성 또는 비어있음.r) scan_onceVERDICT_NOOP_LEGACY_SKIPQUARANTINE_DIR_REL==zN%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py8)s {%(py8)s = %(py5)s(%(py6)s) }lenbefore task_filespy0r'r(r py6py8u*사전 조건: 파일 생성 수 불일치 >assert %(py10)spy10N@@TFcyNenabledrr>rz8test_legacy_cutoff_noop_skip_zero_move..r> legacy_cutoffactivation_epoch launcher_fnwrite_evidence max_files flag_reader>=zN%(py3)s {%(py3)s = %(py0)s(%(py1)s) } >= %(py8)s {%(py8)s = %(py5)s(%(py6)s) } task_recordsutask-* 파일 u개에 대한 record 부족: u건z/%(py2)s {%(py2)s = %(py0)s.verdict } == %(py4)srecrnrwr py4 : verdict=u (NOOP_LEGACY_SKIP 기대) >assert %(py6)srxis)z3%(py2)s {%(py2)s = %(py0)s.quarantined } is %(py5)srwr r u8: quarantined=True — legacy skip 시 quarantine 금지 >assert %(py7)sr )z%(py0)s == %(py2)safter)rwr uOscan 전후 events 디렉토리 파일 목록이 달라졌습니다. before: z after: z >assert %(py4)sr/z0%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py6)squarantine_filesrwr'r(rxu<quarantine 디렉토리에 파일이 생성되었습니다:  >assert %(py8)sry)dispatch.anu_pickup_driverrmrnrorWr]rksetrblistdirrdrsr/r0r2r3r4r1r5r6r7ra result_pathverdict quarantinedsortedreplacesepexistslistiterdir)rTrmrnrorUrurtr: @py_assert7 @py_assert4 @py_format9 @py_format11 future_epochrecordsrrrr @py_assert1 @py_assert3 @py_format5 @py_format7r< @py_format8 @py_format3quarantine_dirr @py_assert5s r&test_legacy_cutoff_noop_skip_zero_movers "(+J8#J/JC O, -F v;W#j/W;/ )WWW;/WWWWWW3WWW3WWWWWWvWWWvWWW;WWWWWW#WWW#WWWWWWjWWWjWWW/WWW+WWWWWWWW99;'L H %%G  3z?+ ,E '8!!--A8L8 | J  /    !$!$%/%/!0 Z))Fsrrz&test_non_target_noop..8rr>)rgrrrrrprrrsrnon_target_pathsrvu비대상 파일 u개에 대해 record u 건 반환rzr{rrrrru (NOOP_NOT_TARGET 기대)rrx)rrmrrWr]r[rarbrcrdrsr/r0r2r3r4r1r5r6r7rr)rTrmrrUnon_target_namesrirjrh target_filenrrr:rrrrrrrrrs rtest_non_target_nooprs "(+J8 !1   TG ,IIK%'  Q)Y/0 1<rrz2test_no_real_spawn_launcher_none..]rr>rrrrsrrurvzassert %(py10)sr{rpr wake_recordsru.launcher_fn=None 인데 WAKE_BUILT record 가 u건 발생했습니다rryrrrnrruA — launcher_fn=None + legacy_cutoff 시 NOOP_LEGACY_SKIP 기대rrxr)z4%(py2)s {%(py2)s = %(py0)s.fire_cron_id } is %(py5)srz: fire_cron_id=u& — launcher_fn=None 인데 설정됨rr )rrmrnrrWr]rkrardrrsr/r0r2r3r4r1r6r7rr5 fire_cron_id)rTrmrnrrUrurrrrr:rrrrrrrrrrrr<rs r test_no_real_spawn_launcher_nonerDsy "(+J8#J))7J 99;'L H %%G '8!!--A8L8 | /J/  //// //////3///3//////|///|/// ///////////////J///J////////// ,O!qyyrs# WW__RWW__RWW__RWW__X=V-WX Y SXXHHOOAz":&3mC;;??:. j"-3  s{{+\QqJ!,,{B[q\ KKO (D ( ($'Z(8:(E$F#G E :95 99T9T!9999599999599959999999999T9999999999999T9999999999999 4  'D"CKK  LLT"j)5OP Z9>RS WW\\*h ;L M  *.2 23&: z. b/ E ]s N!1N!