Rj:PdZddlmZddlZddlmcmZddl Z ddl Z ddl Z ddl Z ddlZddlmZddlmZddlZe j(j+ddZeedz d z d z Ze j0j3d eZe j0j7eZej:j=eej>Zej@Z ejBZ!d+d Z"d+d Z#d+dZ$d+dZ%d+dZ&d+dZ'd+dZ(dZ)dZ*dZ+d,dZ,d-dZ-e-Z.ej^jae. dd+dZ1eedz dz Z2eedz dz Z3eedz dz dz Z4eedz dz d z Z5e jld!Z7d.d"Z8d.d#Z9d.d$Z:d/d%Z;d.d&Zd.d)Z?d.d*Z@y)1u\task-2962: 성공 알림 단일 소유자 + O_EXCL 원자적 선점 규약 회귀 테스트.) annotationsN)ThreadPoolExecutor)PathWORKSPACE_ROOTz/home/jay/workspacescriptslibznotify_claim.py notify_claimc |dz }t|}t|}d}||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}t|}t|}d }||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}y ) uE동일 마커에 대해 첫 claim은 True, 두 번째 claim은 False. notify.markerTiszN%(py6)s {%(py6)s = %(py0)s(%(py4)s {%(py4)s = %(py1)s(%(py2)s) }) } is %(py9)sclaim_notificationstrmarkerpy0py1py2py4py6py9assert %(py11)spy11NF) rr @pytest_ar_call_reprcompare @py_builtinslocals_should_repr_global_name _safereprAssertionError_format_explanationtmp_pathr @py_assert3 @py_assert5 @py_assert8 @py_assert7 @py_format10 @py_format12s ;/home/jay/workspace/tests/test_notify_single_owner_claim.py/test_claim_notification_first_true_second_falser,"s  'F!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222!&k3 k *3e3 *e 3333 *e333333 333 333333c333c333333&333&333k333 *333e3333333c |dz dz dz }|j}|j}|}| }|sddtjvst j |rt j |ndt j |t j |t j |dz}tt j|dx}x}x}}t|}t|}d}||u}|sSt jd |fd ||fd tjvst j trt j tnd d tjvst j trt j tnd dtjvst j |rt j |ndt j |t j |t j |d z}dd|iz} tt j| dx}x}x}}|j}|j}|}|sddtjvst j |rt j |ndt j |t j |t j |dz} tt j| dx}x}}|j}|}|sddtjvst j |rt j |ndt j |t j |dz} tt j| dx}}y)uK부모 디렉토리가 없어도 claim_notification이 자동 생성한다.nesteddeepr zaassert not %(py6)s {%(py6)s = %(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.parent }.exists }() }r)rrrrNTr rrrrrrz]assert %(py6)s {%(py6)s = %(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.parent }.is_dir }() }zAassert %(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.exists }() }rrr) parentexistsrrrrr r!r"rrris_dir) r$r @py_assert1r%r&r( @py_format8r'r)r* @py_format7 @py_format5s r+*test_claim_notification_creates_parent_dirr9)s   6 )O ;F}}%}##%#%%% %% %%%%%%v%%%v%%%}%%%#%%%%%%%%%%!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222 ==!=  !  !! !!!!!!6!!!6!!!=!!! !!! !!!!!!! ===??66=?r-c t|dz }t|}t|}d}||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}tt||j}|}| }|sd dt j vstj |rtj|ndtj|tj|d z} ttj| d x}x}}t|}t|}d}||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}y )uUclaim -> release -> 재claim 이 True (전송 실패 시 재시도 가능해야 함).r Tr rrrrrrrNEassert not %(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.exists }() }r1) rrrrrrrr r!r"release_notificationr3) r$rr%r&r'r(r)r*r5 @py_format6s r+"test_release_then_reclaim_succeedsr>5s  'F!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222V%}}}  vv}!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222r-c|dz }|j}|}| }|sddtjvstj|rtj |ndtj |tj |dz}t tj|dx}x}}tt|y)uW존재하지 않는 마커에 release를 호출해도 예외가 발생하지 않는다.znever-claimed.markerr;rr1N) r3rrrrr r!r"r<r)r$rr5r%r&r=s r+(test_release_nonexistent_marker_no_raiser@>sy . .F}}}  vv}V%r-c $|dz }t|}t|}d}||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}d d dd}tt|||jd} tj| } | |k(} | stjd| fd| |fdt j vstj | rtj| nddt j vstj |rtj|nddz} dd| iz} ttj| d } y )uWclaim -> finalize(payload) 후 마커 파일에 JSON이 기록되고 json.loads 가능.r Tr rrrrrrrNz task-2962success)task_idstatusnutf-8encoding==z%(py0)s == %(py2)sloadedpayloadrrzassert %(py4)sr)rrrrrrrr r!r"finalize_notification read_textjsonloads)r$rr%r&r'r(r)r*rNrawrMr5 @py_format3r8s r+!test_finalize_writes_json_payloadrVHst  'F!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222%CG#f+w/   G  ,C ZZ_F W 6W66WWr-c ,|dz }t|}t|}d}||u}|sStjd|fd||fdt j vstj trtjtnddt j vstj trtjtnddt j vstj |rtj|ndtj|tj|tj|dz}d d |iz}ttj|d x}x}x}}tt|d y ) uMfinalize를 payload=None으로 호출해도 예외가 발생하지 않는다.r Tr rrrrrrrN) rrrrrrrr r!r"rPr#s r+(test_finalize_with_none_payload_no_raiserXSs  'F!&k2 k *2d2 *d 2222 *d222222 222 222222c222c222222&222&222k222 *222d2222222#f+t,r-c >|dz }d}t|5}t|Dcgc]!}|jtt |#}}|Dcgc]}|j }}dddt }||k(} | s#tjd| fd||fdtjvstjt rtjt nddtjvstj|rtj|ndtj|d tjvstj|rtj|nd d z} d d | iz} ttj| dx}} |j} d } | | }d}||k(}|stjd|fd||fdtjvstj|rtj|ndtj| tj| tj|tj|dz}tj d|dzd|iz}ttj|dx} x} x}x}}|j} d} | | }d}||z }||k(}|stjd|fd||fdtjvstj|rtj|ndtj| tj| tj|d tjvstj|rtj|nd tj|dz}dd|iz}ttj|dx} x} x}x}x}}ycc}wcc}w#1swYxYw)uMN=20 스레드가 동일 마커를 동시에 claim -> True는 정확히 1개.zconcurrent-thread.marker) max_workersNrJz0%(py3)s {%(py3)s = %(py0)s(%(py1)s) } == %(py5)slenresults n_workersrrpy3py5assert %(py7)spy7TrCzK%(py6)s {%(py6)s = %(py2)s {%(py2)s = %(py0)s.count }(%(py4)s) } == %(py9)srrrrrTrue 개수가 1이 아님:  >assert %(py11)srFzX%(py6)s {%(py6)s = %(py2)s {%(py2)s = %(py0)s.count }(%(py4)s) } == (%(py8)s - %(py10)s)rrrrpy8py10assert %(py13)spy13)rrangesubmitrrresultr]rrrrrr r!r"count_format_assertmsg)r$rr_executor_futuresfr^ @py_assert2 @py_assert4r=r6r5r%r&r'r(r)r* @py_assert9 @py_assert11 @py_format14s r+/test_concurrent_claim_thread_pool_single_winnerr}]s 2 2FI  20hFKIFV ABHOO.F <  (//!188:// 0 w<$<9 $$$$<9$$$$$$3$$$3$$$$$$w$$$w$$$<$$$$$$9$$$9$$$$$$$ ==MM= M!M ! #MMM !MMMMMM7MMM7MMM=MMMMMM MMM!MMM'CG9%MMMMMMMM ==00= 0q09q=0 = 0000 =00000070007000=000000 00000090009000q00000000 0 00s(P&PPP %P PPg4@g>@zimport multiprocessing def _f(x): return x if __name__ == '__main__': ctx = multiprocessing.get_context('fork') with ctx.Pool(processes=2) as pool: r = pool.map(_f, [1, 2]) assert r == [1, 2] print('MP_PROBE_OK') c  d|d|d|d|d S)Navimport multiprocessing, importlib.util def _claim(args): mpath, mkpath = args spec = importlib.util.spec_from_file_location('notify_claim_mp_worker', mpath) mod = importlib.util.module_from_spec(spec) spec.loader.exec_module(mod) return mod.claim_notification(mkpath) if __name__ == '__main__': ctx = multiprocessing.get_context('fork') args = [(z, z)] * z with ctx.Pool(processes=za) as pool: results = pool.map(_claim, args) print(','.join(str(r) for r in results)) ) module_path marker_pathr_s r+_mp_claim_scriptrs4 $buYKH''0k29 9r-c tjddtgddt}|jdk(xrd|j vS#t $rYywxYw)u이 실행 환경이 multiprocessing(fork)을 실제로 지원하는지 격리된 서브프로세스로 확인. hang 하더라도 subprocess.run의 timeout이 강제로 끊어주므로 이 함수는 collection을 절대 블로킹하지 않는다. python3-cTcapture_outputtexttimeoutr MP_PROBE_OKF) subprocessrun_MP_PROBE_SCRIPT_MP_PROBE_TIMEOUT_S returncodestdout Exception)rqs r+_detect_mp_availablers\  . /'     A%H-6==*HH sAA AAu)이 환경에서 multiprocessing(fork)이 동작하지 않음 (세마포어/샌드박스 clone 제약으로 추정 — 격리된 서브프로세스 프로브가 hang/실패함). 프로세스 간 O_EXCL 보장은 스레드 테스트(test_concurrent_claim_thread_pool_single_winner)로 대체 커버)reasonc T |dz }d}tttt||} tjdd|gddt }j}d }||k(}|stjd |fd ||fdtjvstj |rtj"|ndtj"|tj"|dz} tj$d|jd|jd |jdzd| iz} t'tj(| d x}x}}|jj+j-d} | D cgc]} | dk( } } t/| }||k(}|sLtjd |fd||fdtjvstj t.rtj"t.nddtjvstj | rtj"| ndtj"|dtjvstj |rtj"|nddz} tj$dt/| d|d| ddzd| iz} t'tj(| d x}}| j0}d}||}d}||k(}|stjd |fd ||fdtjvstj | rtj"| ndtj"|tj"|tj"|tj"|d!z}tj$d"| d#zd$|iz}t'tj(|d x}x}x}x}}| j0}d%}||}d}||z }||k(}|stjd |fd&||fdtjvstj | rtj"| ndtj"|tj"|tj"|dtjvstj |rtj"|ndtj"|d'z}d(d)|iz}t'tj(|d x}x}x}x}x}}y #tj $rA}tjdt d|jd |jYd }~Qd }~wwxYwcc} w)*uN=20 프로세스가 동일 마커를 동시에 claim -> True는 정확히 1개 (프로세스 간 O_EXCL 보장). 실제 claim 호출도 격리된 서브프로세스에서 수행하고 hard timeout을 건다. (mp 자체는 가용하다고 프로브에서 확인했으므로, 여기서 timeout이 발생하면 claim_notification 구현의 fork 안전성 문제로 간주해 실패 처리한다.) zconcurrent-mp.markerrZrrTru/멀티프로세스 claim 서브프로세스가 uDs 내에 끝나지 않음 (fork 안전성 문제 가능성): stdout= stderr=NrrJz2%(py2)s {%(py2)s = %(py0)s.returncode } == %(py5)srqrrrbu9멀티프로세스 claim 서브프로세스 실패 (exit= ): stdout= >assert %(py7)srd,Truer\r]r^r_r`u결과 개수 불일치: z != z (raw=)rCrerfrgrhrFrirjrmrn)rr_NOTIFY_CLAIM_PATHrr_MP_CLAIM_TIMEOUT_STimeoutExpiredpytestfailrstderrrrrrrrr rsr!r"stripsplitr]rr)r$rr_scriptrqexcr5ryr%r=r6 raw_resultsrr^rxr&r'r(r)r*rzr{r|s r+3test_concurrent_claim_multiprocessing_single_winnerrsW . .FI c"45s6{I NF   f %'       !    !" DFDUDUCVW--"(6==*; =--%%'--c2K$/0qqF{0G0 w<<9 $<9   %% $CL>i[{oUVW ==QQ= Q!Q ! #QQQ !QQQQQQ7QQQ7QQQ=QQQQQQ QQQ!QQQ'CK=%QQQQQQQQ ==00= 0q09q=0 = 0000 =00000070007000=000000 00000090009000q00000000%  $ $  =>Q=RSJJM**Xjj^ %   1s U> V%V"!6VV"zdone-watcher.shzactivity-watcher.pydeploysystemdzactivity-watcher.servicezdone-watcher.servicez"\$\{?COKACDIR_CHAT_ID(:-[^}]*)?\}?cztjd}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}dd |iz}ttj|d x}}y ) uZdone-watcher.sh 텍스트에 DONE_WATCHER_SH_SUCCESS_NOTIFY 가드가 존재해야 한다.rGrHDONE_WATCHER_SH_SUCCESS_NOTIFYinz%(py1)s in %(py3)scontentrraassert %(py5)srbN) _DONE_WATCHER_SHrQrrr rrrr!r"r @py_assert0rx @py_format4r=s r+-test_done_watcher_sh_has_success_notify_guardrsq(('(:G +6 +w 6666 +w666 +666666w666w6666666r-cztjd}d}||v}|stjd|fd||ftj|dt j vstj|rtj|nddz}dd |iz}ttj|d x}}y ) u_activity-watcher.py 텍스트에 ACTIVITY_WATCHER_SUCCESS_NOTIFY 가드가 존재해야 한다.rGrHACTIVITY_WATCHER_SUCCESS_NOTIFYrrrrrrbN) _ACTIVITY_WATCHER_PYrQrrr rrrr!r"rs r+1test_activity_watcher_py_has_success_notify_guardrsq",,g,>G ,7 , 7777 ,777 ,7777777777777777r-ctjd}g}tj|D]:}|j d}|j drd|vr*|j |<| }|s~tjd|dzdd tjvstj|rtj|nd iz}ttj|d }y ) udone-watcher.sh 에 COKACDIR_CHAT_ID 가 가드 없는 bare 참조로 남아있지 않아야 한다. ${COKACDIR_CHAT_ID:-...} 형태(디폴트 값 가드)만 허용한다. rGrHrz${z:-u3가드 없는 bare COKACDIR_CHAT_ID 참조 발견: z >assert not %(py0)sr bare_matchesN)rrQ_CHAT_ID_REF_REfinditergroup startswithappendrrsrrrr r!r")rrmfullr5 @py_format2s r+.test_done_watcher_sh_no_bare_chat_id_referencers (('(:GL  % %g ."wwqz ??4 TT\ D! "  a aaRS_R`aaaaaaa|aaa|aaaaaar-c|jD]<}|j}|jdr%tjd|s<yy)u 실제 systemd `EnvironmentFile=` 지시자 라인이 있는지 검사한다. 주석(`#...`)에 설명 목적으로 "EnvironmentFile=" 문자열이 등장하는 것은 허용한다 — 실제 지시자로 파싱될 라인만 위반으로 간주한다. #z^EnvironmentFile\s*=TF) splitlinesrrrematch)rlinestrippeds r+_has_environmentfile_directiver sO ""$::<   s #  88+X 6  r-ctjd}t|}| }|stjddzdt j vstjtrtjtnddt j vstj|rtj|ndtj|dz}ttj|dx}}y) u activity-watcher.service 에 EnvironmentFile= 지시자가 없어야 한다. (.env.keys 의 `export` 접두 때문에 systemd EnvironmentFile= 파싱이 실패하는 함정을 해소 — load-env-keys.sh 를 통한 source 방식으로 대체되어야 함) rGrHuKactivity-watcher.service 에 실제 EnvironmentFile= 지시자가 존재함2 >assert not %(py3)s {%(py3)s = %(py0)s(%(py1)s) }rrrrraN) _ACTIVITY_WATCHER_SERVICErQrrrsrrrr r!r"rrxryr8s r+4test_activity_watcher_service_has_no_environmentfilers (1171CG-g66 6 6 V../6/67r-ctjd}t|}| }|stjddzdt j vstjtrtjtnddt j vstj|rtj|ndtj|dz}ttj|dx}}y) uHdone-watcher.service 에 EnvironmentFile= 지시자가 없어야 한다.rGrHuGdone-watcher.service 에 실제 EnvironmentFile= 지시자가 존재함rrrrN) _DONE_WATCHER_SERVICErQrrrsrrrr r!r"rs r+0test_done_watcher_service_has_no_environmentfiler$s#--w-?G-g66 6 6 R../6/67r-cttdz dz }tj|j d}t |dS)Nconfigzconstants.jsonrGrHchat_id)rrrRrSrQr)constants_pathdatas r+_expected_chat_idr/sB.)H47GGN ::n...@ AD tI r-c t}d}tjdd|gtitj dtiddd}|j }d}||k(}|stjd |fd ||fd tjvstj|rtj|nd tj|tj|d z}tjd |j d|jd|jdzd|iz}t!tj"|dx}x}}|jj%}||k(}|stjd |fd||fdtjvstj|rtj|nddtjvstj|rtj|nddz} tjd|d|d|jddzd| iz} t!tj"| d}y)uWload-env-keys.sh source 후 COKACDIR_CHAT_ID 가 constants.json 의 chat_id 와 일치.zWset -u; source "$WORKSPACE_ROOT/scripts/lib/load-env-keys.sh"; echo "$COKACDIR_CHAT_ID"bashrrTcwdenvrrrrrJrrqru%load-env-keys.sh source 실패 (exit=rrrrdNrLactualexpectedrOu COKACDIR_CHAT_ID 불일치: got=z expected=z (stderr=rz >assert %(py4)sr)rrrrosenvironrrrrrrr rsrrr!r"r) rrrqr5ryr%r=r6rrUr8s r+.test_load_env_keys_sets_chat_id_from_constantsr5s "H # ^^ v  r@rVrXr}rrrrr _MP_AVAILABLEmarkskipifrrrrrcompilerrrrrrrrrrrr-r+rsb" 1  02GH.)I5=@QQ..~?QR//6  '"55$99%;; 43&- 1,!$$%&  $1$1Z')36GGN+i7:OO8#i/2LL 8#i/2HH "**BC7 8 b   4&r-