&validate_pipeline(yaml_dict) -> list[str] 테스트 스위트.cjddl}|jt}t|}|gk(s Jd|y)uP유효한 YAML dict를 전달하면 빈 에러 리스트를 반환해야 한다.rNu5유효한 파이프라인에서 에러가 발생함: )copydeepcopyr#rselfr'pipelineerrorss O/home/jay/workspace/.worktrees/task-2057-dev2/orchestrator/tests/test_phase2.py(test_valid_pipeline_returns_empty_errorsz>TestPipelineValidator.test_valid_pipeline_returns_empty_errorsTs8==0"8,|]TU[T\]]|cddl}|jt}|d=t|}t |dkDsJdt d|Ds Jd|y)uDschema_version 필드가 누락되면 에러를 반환해야 한다.rNru,schema_version 누락인데 에러가 없음c3$K|]}d|v yw)rN.0es r- zRTestPipelineValidator.test_missing_schema_version_returns_error..fs &'  ! u4에러 메시지에 'schema_version' 언급 없음: r'r(r#rlenanyr)s r-)test_missing_schema_version_returns_errorz?TestPipelineValidator.test_missing_schema_version_returns_error^sl==0 % &"8,6{QN NN +1   K A& J K r/cddl}|jt}|d=t|}t |dkDsJdt d|Ds Jd|y)u;gates 필드가 누락되면 에러를 반환해야 한다.rNr u#gates 누락인데 에러가 없음c3$K|]}d|v ywr Nr2r3s r-r6zITestPipelineValidator.test_missing_gates_returns_error..t0A7a<0r7+에러 메시지에 'gates' 언급 없음: r8r)s r- test_missing_gates_returns_errorz6TestPipelineValidator.test_missing_gates_returns_errorls^==0 W "8,6{QE EE000h4_`f_g2hh0r/cddl}|jt}g|d<t|}t |dkDsJdt d|Ds Jd|y)u;gates가 빈 리스트이면 에러를 반환해야 한다.rNr u-gates가 빈 리스트인데 에러가 없음c3$K|]}d|v ywr>r2r3s r-r6zGTestPipelineValidator.test_empty_gates_returns_error..~r?r7r@r8r)s r-test_empty_gates_returns_errorz4TestPipelineValidator.test_empty_gates_returns_errorvs`==0"8,6{QO OO000h4_`f_g2hh0r/cddl}|jt}|d=t|}t |dkDsJdt d|Ds Jd|y)uBtoken_budget 필드가 누락되면 에러를 반환해야 한다.rNru*token_budget 누락인데 에러가 없음c3$K|]}d|v ywrNr2r3s r-r6zPTestPipelineValidator.test_missing_token_budget_returns_error.. $%Na  r72에러 메시지에 'token_budget' 언급 없음: r8r)s r-'test_missing_token_budget_returns_errorz=TestPipelineValidator.test_missing_token_budget_returns_errorsk==0 ^ $"8,6{QL LL )/   I ?x H I r/cddl}|jt}d|d<t|}t |dkDsJdt d|Ds Jd|y)u;token_budget이 음수이면 에러를 반환해야 한다.rNru*token_budget 음수인데 에러가 없음c3$K|]}d|v ywrGr2r3s r-r6zQTestPipelineValidator.test_negative_token_budget_returns_error..rHr7rIr8r)s r-(test_negative_token_budget_returns_errorz>TestPipelineValidator.test_negative_token_budget_returns_errorsm==0#% "8,6{QL LL )/   I ?x H I r/cddl}|jt}d|d<t|}t |dkDsJdt d|Ds Jd|y)uSblast_radius에 허용되지 않는 값이 있으면 에러를 반환해야 한다.rNuniverseru-잘못된 blast_radius인데 에러가 없음c3$K|]}d|v yw)rNr2r3s r-r6zPTestPipelineValidator.test_invalid_blast_radius_returns_error..rHr7u2에러 메시지에 'blast_radius' 언급 없음: r8r)s r-'test_invalid_blast_radius_returns_errorz=TestPipelineValidator.test_invalid_blast_radius_returns_errorsm==0#- "8,6{QO OO )/   I ?x H I r/cddl}|jt}g|d<t|}t |dkDsJdt d|Ds Jd|y)u?allowed_teams가 비어있으면 에러를 반환해야 한다.rNru5allowed_teams가 빈 리스트인데 에러가 없음c3$K|]}d|v yw)rNr2r3s r-r6zOTestPipelineValidator.test_empty_allowed_teams_returns_error..s %&Oq  r7u3에러 메시지에 'allowed_teams' 언급 없음: r8r)s r-&test_empty_allowed_teams_returns_errorz.s< QRGqwwy LJ!'')$; Lx1} L s68u1에러 메시지에 순환 관련 언급 없음: r8r)s r-test_cyclic_dag_returns_errorz3TestPipelineValidator.test_cyclic_dag_returns_errors==0*&@#%'j  *&@#%'j  *&@#%'j  # 4#8,6{QC CC V\   H >vh G H r/cddl}|jt}ddddddgdg|d <t|}t |dkDsJd t d |Ds Jd |y) uUstep이 자기 자신을 depends_on으로 참조하면 에러를 반환해야 한다.rNrz Self Loopr rrrYr"u)자기 참조 step인데 에러가 없음c3K|]J}d|jvxs2d|jvxsd|jvxs d|vxsd|vLyw)r*r]r^u자기r_Nr`r3s r-r6zOTestPipelineValidator.test_self_reference_step_returns_error..sl  aggi  !'')# QWWY& 1} 1}   sAAu8에러 메시지에 자기 참조/순환 언급 없음: r8r)s r-&test_self_reference_step_returns_errorz.sR   ! aUaggi%7 a5AGGI;M aQ\`aQa a sA A u4에러 메시지에 시크릿 관련 언급 없음: r8r)s r-5test_secret_pattern_aws_key_in_pipeline_returns_errorzKTestPipelineValidator.test_secret_pattern_aws_key_in_pipeline_returns_errorsp==0L"8,6{QP PP    KB& J K r/cddl}|jt}d|ddd<t|}t |dkDsJdt d|Ds Jd|y) uPstep의 target_team이 allowed_teams에 없으면 에러를 반환해야 한다.rNzunauthorized-teamr"ru6허용되지 않은 target_team인데 에러가 없음c3XK|]"}d|vxsd|vxsd|jv$yw)rrr Nr`r3s r-r6z\TestPipelineValidator.test_target_team_not_in_allowed_teams_returns_error..s7 RSMQ  M/Q"6 M&AGGI:M M (*u6에러 메시지에 target_team 관련 언급 없음: r8r)s r-3test_target_team_not_in_allowed_teams_returns_errorzITestPipelineValidator.test_target_team_not_in_allowed_teams_returns_error sw==0.A!]+"8,6{QX XX W]   M CF8 L M r/cddl}|jt}dg|ddd<t|}t |dkDsJdt d|Ds Jd |y) uUdepends_on에 존재하지 않는 step id가 있으면 에러를 반환해야 한다.rNznonexistent-step-999r"ruM존재하지 않는 step id를 depends_on에 참조하는데 에러가 없음c3XK|]"}d|vxsd|jvxsd|v$yw)r nonexistentu없Nr`r3s r-r6zWTestPipelineValidator.test_depends_on_nonexistent_step_returns_error..!s6 NOLA  I!'')!; Iuz I rnu5에러 메시지에 depends_on 관련 언급 없음: r8r)s r-.test_depends_on_nonexistent_step_returns_errorzDTestPipelineValidator.test_depends_on_nonexistent_step_returns_errorsz==0.D-E!\*"8,6{Qo oo SY   L B6( K L r/cddl}|jt}d|ddd<t|}t |dkDsJdt d|Ds Jd|y) uQstep의 task_desc에 인젝션 패턴이 있으면 에러를 반환해야 한다.rNz.2sN   ! e[A%5 e9I e[\]\c\c\eMe e <>u4에러 메시지에 인젝션 관련 언급 없음: r8r)s r-1test_injection_pattern_in_task_desc_returns_errorzGTestPipelineValidator.test_injection_pattern_in_task_desc_returns_error's==0 K !  #8,6{Q] ]]    KB& J K r/cddl}|jt}ddd|ddd<t|}t |dkDsJdt d |Ds Jd |y) ufinject_context.source에 path traversal (../../etc/passwd)이 있으면 에러를 반환해야 한다.rNz../../etc/passwdtext)sourceformatr"inject_contextu,path traversal이 있는데 에러가 없음c3K|]6}d|jvxsd|jvxs d|vxsd|v8yw) traversalpathru경로Nr`r3s r-r6zcTestPipelineValidator.test_path_traversal_in_inject_context_source_returns_error..DsN  1779 $ e!'')(; e?OST?T eX`deXe e rzu9에러 메시지에 path traversal 관련 언급 없음: r8r)s r-:test_path_traversal_in_inject_context_source_returns_errorzPTestPipelineValidator.test_path_traversal_in_inject_context_source_returns_error9s==0(2 !-.#8,6{QN NN    PGvh O P r/N)__name__ __module__ __qualname____doc__r.r;rArDrJrNrRrUrbrerkrortr{rr2r/r-r%r%Os`H^ Kii I I I J#HNO8 K M LK$Pr/r%c^eZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZy)TestTokenLedgeru*TokenLedger 클래스 테스트 스위트.c2t|dz }|Jdy)uKTokenLedger(ledger_path)로 인스턴스를 생성할 수 있어야 한다. ledger.jsonNu&TokenLedger 인스턴스 생성 실패rr*tmp_pathledgers r-test_token_ledger_instantiationz/TestTokenLedger.test_token_ledger_instantiationRs#X 56!K#KK!r/ct|dz }|jdd|j}|dk(s Jd|dy)uVrecord_usage(pipeline_id, tokens)를 호출하면 사용량이 기록되어야 한다.r pipeline-001iu7기록 후 일일 사용량이 1000이어야 하는데 임Nr record_usageget_daily_usager*rrusages r-test_record_usage_stores_tokensz/TestTokenLedger.test_record_usage_stores_tokensWsMX 56ND1&&(}b WX]W^^abb}r/ct|dz }|jdd|jdd|j}|dk(s Jd|dy) uS여러 번 record_usage를 호출하면 누적 사용량이 합산되어야 한다.rri iiu,누적 사용량이 5000이어야 하는데 rNrrs r-$test_record_usage_accumulates_tokensz4TestTokenLedger.test_record_usage_accumulates_tokens^s[X 56ND1ND1&&(}W LUGSVWW}r/c~t|dz }|jdd|jdd}|dusJdy)uA일일 한도 내에서 can_spend는 True를 반환해야 한다.rri iTu0한도 내인데 can_spend가 False를 반환함Nrr can_spendr*rrresults r-(test_can_spend_returns_true_within_limitz8TestTokenLedger.test_can_spend_returns_true_within_limitfsEX 56NG4!!.':~QQQ~r/c~t|dz }|jdd|jdd}|dusJdy)uQDAILY_HARD_LIMIT(1,000,000) 초과 시 can_spend는 False를 반환해야 한다.rr@BrqFu<DAILY_HARD_LIMIT 초과인데 can_spend가 True를 반환함Nrrs r-;test_can_spend_returns_false_when_daily_hard_limit_exceededzKTestTokenLedger.test_can_spend_returns_false_when_daily_hard_limit_exceededmsEX 56NI6!!.!4^ ^^r/cht|dz }|jdk(sJd|jdy)u9DAILY_HARD_LIMIT 상수 값이 1,000,000이어야 한다.rru1DAILY_HARD_LIMIT가 1,000,000이어야 하는데 rN)rDAILY_HARD_LIMITrs r--test_daily_hard_limit_constant_is_one_millionz=TestTokenLedger.test_daily_hard_limit_constant_is_one_millionusBX 56  # #y 0 \ >v?V?V>WWZ [ \ 0r/ct|dz }|j}t|tsJdt |y)u0get_daily_usage()는 int를 반환해야 한다.ru2get_daily_usage() 반환 타입이 int가 아님: N)rr isinstanceintrrs r- test_get_daily_usage_returns_intz0TestTokenLedger.test_get_daily_usage_returns_int|sDX 56&&(%%i)[\`af\g[h'ii%r/cTt|dz }|jdk(sJdy)u-초기 일일 사용량은 0이어야 한다.rru9초기 사용량이 0이어야 하는데 그렇지 않음N)rrrs r-$test_get_daily_usage_initial_is_zeroz4TestTokenLedger.test_get_daily_usage_initial_is_zeros.X 56%%'1,i.ii,r/ct|dz }|jdd|jdd|jdd|jdd}|dusJdy ) uYMAX_CONCURRENT_PIPELINES(3) 초과 시 새 파이프라인 시작을 거부해야 한다.rrdz pipeline-002z pipeline-003z pipeline-004FuGMAX_CONCURRENT_PIPELINES(3) 초과인데 can_spend가 True를 반환함Nrrs r-.test_max_concurrent_pipelines_exceeded_rejectsz>TestTokenLedger.test_max_concurrent_pipelines_exceeded_rejectsseX 56NC0NC0NC0!!.#6i iir/ct|dz }tdD]}|jd|dd|jdd}|dusJdy ) u]MAX_PIPELINE_STARTS_PER_DAY(20) 초과 시 새 파이프라인 시작을 거부해야 한다.rz pipeline-03drz pipeline-020FuKMAX_PIPELINE_STARTS_PER_DAY(20) 초과인데 can_spend가 True를 반환함N)rrangerr)r*rrirs r-1test_max_pipeline_starts_per_day_exceeded_rejectszATestTokenLedger.test_max_pipeline_starts_per_day_exceeded_rejectsscX 56r :A   )Ac7 3S 9 :!!.#6m mmr/cht|dz }|jdk(sJd|jdy)u9MAX_CONCURRENT_PIPELINES 상수 값이 3이어야 한다.ru1MAX_CONCURRENT_PIPELINES가 3이어야 하는데 rN)rMAX_CONCURRENT_PIPELINESrs r-/test_max_concurrent_pipelines_constant_is_threez?TestTokenLedger.test_max_concurrent_pipelines_constant_is_threesBX 56  + +q 0 d >v?^?^>__b c d 0r/cht|dz }|jdk(sJd|jdy)u=MAX_PIPELINE_STARTS_PER_DAY 상수 값이 20이어야 한다.rru5MAX_PIPELINE_STARTS_PER_DAY가 20이어야 하는데 rN)rMAX_PIPELINE_STARTS_PER_DAYrs r-3test_max_pipeline_starts_per_day_constant_is_twentyzCTestTokenLedger.test_max_pipeline_starts_per_day_constant_is_twentysBX 56  . ." 4 k B6CeCeBffi j k 4r/cx ddl}ddlm}t|dz }|j dd|j j |jdz G fdd |j }|j|jd |t|dz }|j}|dk(s Jd |d y) uJ날짜가 변경되면 일일 사용량이 0으로 리셋되어야 한다.rNrriPrq)daysc"eZdZefdZy)ITestTokenLedger.test_daily_usage_resets_on_date_change.._MockDatecS)Nr2)cls future_dates r-todayzOTestTokenLedger.test_daily_usage_resets_on_date_change.._MockDate.todays ""r/N)rrr classmethodr)rsr- _MockDaters  # #r/rdateu4날짜 변경 후 사용량이 0이어야 하는데 r) datetimeorchestrator.token_ledger token_ledgerrrrr timedeltasetattrr) r*r monkeypatchr_tl_modrrledger2rrs @r-&test_daily_usage_resets_on_date_changez6TestTokenLedger.test_daily_usage_resets_on_date_changes3X 56NF3mm))+h.@.@a.@.HH  #  # G,,fi@h67'')z\QRWQXX[\\zr/N)rrrrrrrrrrrrrrrrrr2r/r-rrOsS4L cXR_\j j jndk]r/rc|\}}}ddl}t|jvr |jjdtddlm}||||S)uEmultiprocessing.Pool용 워커: consume_event 결과를 반환한다.rNr)sysWORKSPACE_ROOTrinsertorchestrator.event_busr)args incoming_dir processed_dir event_filer_consumes r-_worker_consume_eventrsA.2+L-SXX% >*@ L- < bool 테스트 스위트.c@|dz }|dz }|j|jd}||z jdtt|t||}|dusJd||z j rJd||z j sJdy ) ulincoming/에 .done 파일이 있을 때 소비하면 processed/로 이동하고 True를 반환해야 한다.incoming processedzpipeline-001.donedoneTu&정상 소비인데 False를 반환함3소비 후에도 incoming에 파일이 남아있음(소비 후 processed에 파일이 없음N)mkdir write_textrstrexistsr*rrrrrs r-*test_consume_event_moves_file_to_processedz7TestEventBus.test_consume_event_moves_file_to_processedsj({* ( J **62s8}c)njI~GGG~z)113j5jj3J&..0\2\\0r/c|dz }|dz }|j|jd}tt|t||}|dusJdy)uo이미 소비된 파일(FileNotFoundError)에 대해 False를 반환해야 한다 (다른 프로세스 선점).rrzpipeline-already-consumed.doneFuk파일이 없는데(이미 소비됨) True를 반환함 — 다른 프로세스 선점 상황 처리 실패N)rrrrs r-/test_consume_event_file_not_found_returns_falsezrs   '!HHOOA~& 0 >1   !;/)  4 &"?!  &"@#*!  !!!RxPxP@q]q]r =UeUer/