&d B  56 >DTU  JL\]  HHRL     :C@s6B B #D1C CDC D C;;Dr2c tj|tjtj d|t j |y#t j |wxYw)ufd에 대한 flock을 해제하고 파일 디스크립터를 닫는다. Args: fd: acquire_global_lock()이 반환한 파일 디스크립터. u전역 락 해제 성공: fd=%dN)r'r(LOCK_UNr+r,r"r.)r2s r4rrus?  B & 6;   s :AA) yaml_pathctjd|t|dd5}tj|}dddt t stdt||S#1swY2xYw)u%YAML 파이프라인 파일을 로드하여 dict를 반환한다. Args: yaml_path: 파이프라인 YAML 파일의 절대/상대 경로. Returns: 파이프라인 dict. Raises: yaml.YAMLError: YAML 구문 오류. OSError: 파일 읽기 오류. u파이프라인 로드: %srutf-8encodingNu.파이프라인 YAML이 dict가 아닙니다: ) r+r,r#yaml safe_load isinstancedict ValueErrortype)r7fhdatas r4rrsj LL-y9 iw /"2~~b!" dD !I$t*VWW K ""s A,,A5pipelinec8t|jddS)u파이프라인 dict에서 enabled 여부를 반환한다. Args: pipeline: 파이프라인 dict (YAML 로드 결과). Returns: enabled 필드가 있으면 그 bool 값, 없으면 True (후방호환). enabledT)boolget)rEs r4rrs  Y- .. incoming_dir processed_dircrt|}t|}|jstjd|gSt }|jr8|j Dchc]}|j s|j!}}g}|j D]m}|j s|jdk(s$|j|vs3|j|jtjd|jotjdt||Scc}w)uincoming_dir에서 미처리 .done 이벤트 파일 목록을 반환한다. 이미 processed_dir에 존재하는 파일은 제외한다. Args: incoming_dir: 미처리 이벤트 파일 디렉터리. processed_dir: 처리 완료된 이벤트 파일 디렉터리. Returns: 미처리 .done 파일명 리스트 (순수 파일명, 경로 제외). u)incoming 디렉터리가 없습니다: %sz.doneu미처리 이벤트 발견: %su scan_events 결과: %d개 파일) rexistsr+warningsetiterdiris_filenamesuffixappendr,len)rKrL incoming_pathprocessed_pathprocessed_filesfresultss r4rrs&M-(N    !BLQ #O+9+A+A+CSaqyy{166SSG  " " $G 99;188w.vv_,qvv& =qvvF G  LL3S\B NTs +D4D4 pipeline_idctjjt|d}tjj |st j d|y t|dd5}|j}dddjst jd|ytj|}t|tst jd|y|S#1swYnxYw#tjt f$r!}t jd ||Yd}~yd}~wt"$r!}t j%d ||Yd}~yd}~wwxYw) uSTATE_DIR/.json을 로드한다. Args: pipeline_id: 파이프라인 식별자. Returns: 상태 dict, 파일 없음 또는 파싱 실패 시 None. .jsonu(파이프라인 상태 파일 없음: %sNr9r:r;u2파이프라인 상태 파일이 비어 있음: %su,파이프라인 상태가 dict가 아님: %su2파이프라인 상태 JSON 파싱 실패 (%s): %su4파이프라인 상태 파일 읽기 오류 (%s): %s)r"pathjoin STATE_DIRrNr+r,r#readstriprOjsonloadsr?r@JSONDecodeErrorrAr0r1)r\ state_filerCcontentrDr3s r4rrsiK=)>?J 77>>* % ?L *cG 4 ggiG }} NNOQ[ \zz'"$% NNI: V     * -KZY\]  KZY\]sHC7-C+>.C7-;C7)C7+C40C77ED,, E8EEstatec,tjtdtjj t|d}t |dd5}t j||dd d d d tjd |y #1swY xYw) uSTATE_DIR/.json에 상태를 저장한다. Args: pipeline_id: 파이프라인 식별자. state: 저장할 상태 dict. T)exist_okr^wr:r;F ensure_asciiindentNu!파이프라인 상태 저장: %s) r"makedirsrar_r`r#rddumpr+r,)r\rirgrCs r4rrsqKK D)iK=)>?J j# 0;B %%:; LL4jA;;s B  Bstepc |jdd|jddd}|jdd}dtjjtd d |d |g}t j d ||jd|| tj|d dd}|jdk(r't jd||jdyt jd||jd|j|jr|jddy dy #t$r }t jd|Yd}~y d}~wwxYw)uSdispatch.py를 서브프로세스로 호출하여 스텝을 실행한다. Args: step: 실행할 스텝 dict (id, target_team, task_file_template 등). pipeline_id: 파이프라인 식별자. state: 현재 파이프라인 상태 dict. Returns: 성공(returncode==0) 시 True, 실패 시 False. task_file_templatezpipelines/templates/idunknownz.md target_teamz unknown-teamz/usr/bin/python3z dispatch.pyz--teamz --task-fileu>dispatch_step 호출: pipeline_id=%s step_id=%s team=%s cmd=%sFT)shellcapture_outputtextru$dispatch 성공: pipeline=%s step=%su<dispatch 실패: pipeline=%s step=%s returncode=%d stderr=%sNudispatch 실행 오류: %s)rIr"r_r`WORKSPACE_ROOTr+r, subprocessrun returncodeinforOstderrr0r1)rsr\ri task_filerxcmdresultr3s r4rr sH-1EdhhtU^F_E``c/deI((=.9K   ^]3 C LLH         ! KK> TXXVZ^ \ NNN!!'-}} ds#  ;=    137s& AD.A D.'D.. E7EEactive_pipelineserrors token_usagectjtjj dj |||dndd}|||d<t t}|jjdd|jtj|d d d tjd|||y)uHEALTH_PATH의 health.json을 갱신한다. Args: active_pipelines: 현재 활성 파이프라인 수. errors: 최근 1시간 내 에러 수. token_usage: 토큰 사용량 dict (옵션). 있으면 version "1.1"로 기록. Ntzinfoz1.1z1.0) last_tickrerrors_last_hourversionrTparentsrkFrmrnr:r;u@health.json 갱신: active_pipelines=%d errors=%d token_usage=%s)rnowrutcreplace isoformatr HEALTH_PATHparentmkdir write_textrddumpsr+r,)rrr health_data health_files r4rrGs\\(,,/77t7DNNP,"'35 K %0 M"{#KTD94::kaP[bc LLJ rJmessage alert_typectt} |jr&tj|j d}ni}tjtjjj}|j|g}||vrtj!d||yt"j$jd}|stj'dyt"j$jd}|stj'dy t)j*d |d ||d d }|j,s/tj'd|j.|j0ddy |j7||||< |j8j;dd|j=tj>|dddtjAd||y#tj tf$ri}YwxYw#t(j2$r } tj5d| Yd} ~ yd} ~ wwxYw#t$r } tj'd| Yd} ~ d} ~ wwxYw)uTelegram Direct API로 경고 발송 (토큰 0, 중복 방지). Args: message: 발송할 메시지 텍스트 alert_type: 경고 유형 (예: "token_warning", "stale_task") Returns: True: 발송 성공 False: 이미 발송됨 또는 실패 r:r;u.경고 이미 발송됨 (중복 방지): %s/%sF ANU_BOT_TOKENuQANU_BOT_TOKEN 환경변수가 설정되지 않음. Telegram 경고 발송 불가.AUTO_ORCH_CHAT_IDuUAUTO_ORCH_CHAT_ID 환경변수가 설정되지 않음. Telegram 경고 발송 불가.zhttps://api.telegram.org/botz /sendMessage)chat_idr{ )rdtimeoutu0Telegram 경고 발송 실패: status=%d body=%sNr|u%Telegram 경고 발송 중 오류: %sTrrmrnu"alerts_sent.json 저장 실패: %su$Telegram 경고 발송 성공: %s/%s)!rALERTS_SENT_PATHrNrdre read_textrfr0rrrrdaterrIr+r,r"environrOrequestspostok status_coder{RequestExceptionr1rUrrrrr) rr alerts_path alerts_data today_key today_alertstokenrrespr3s r4rrgs)'(K     $ ;+@+@'+@+R SKK  X\\*//1;;=I$B7L\! EyR\] JJNN? +E jkjjnn01G no }}*5' >$g6  ww NNMtO_O_aeajajkoloap q #)K B   =tzz+ERST_fg KK6 :N a  ' * D  $ $ }|jA}tC||||jEr-|d}|d}|d}d|dd|dd|dd|d }tG|d tI}|D]0}|d!}|d"}|d#}d$|d%|d&|d'z d(d)}tG|d*|2 tK|y#t0$r'} tj3d| | |d z }Yd} ~ ;d} ~ wwxYw#t0$r2} tj3d+| |d z }tC||,Yd} ~ ud} ~ wwxYw#tK|wxYw)-ui--scan: 전역 락 획득 → 이벤트 소비 → 파이프라인 스텝 디스패치 → health 갱신.NuP다른 auto_orch 프로세스가 실행 중입니다. 스캔을 건너뜁니다.ru이벤트 소비 완료: %su3이벤트 소비 실패 또는 이미 처리됨: %sTr*.jsonrr})rpending.yamlu파이프라인 YAML 없음: %su+파이프라인 YAML 로드 실패 (%s): %su2파이프라인 비활성화 상태 — 스킵: %ssteps current_steprvrxu3팀 락 보유 중 — 디스패치 대기: team=%s)rrrtodaylimit remainingu2⚠️ 일일 토큰 사용량 80% 도달 사용: , / u 잔여: u 토큰 활성 파이프라인: 개 token_warningrrru-⚠️ 스텝 타임아웃 감지 태스크: u 팀: u 경과: iz.1fu시간 stale_task_u%cmd_scan 실행 중 예외 발생: %s)rr)&rr+rOr EVENTS_DIR INCOMING_DIR PROCESSED_DIRrrrr,rrarNrglobstemrrIr"r_r` PIPELINES_DIRrr/r1rr is_team_availablerr LEDGER_PATHget_daily_usage_summaryrcheck_warning_thresholdrrr)r2 errors_count active_count new_events event_fileconsumed state_pathrgr\rir pipeline_yamlrEr3rcurrent_step_idrsrxsuccessledger usage_summaryrrrmsg stale_tasksrrrrs r4rrs  B zijLLe \=A!}= $ `J$\=*MH 9:F RT^_  `)_   "   TD  9$//(3* eJ$//K&{3E}YYx,F33 A LGGLL;-u8MNM77>>-0 > N (7'x0 QS^_ ( Wb 9E#ii7O e88D>_4"hh}b9 --k:+D+uEG"$) LL!VXcd eC* eZ[)668  |LVcd  ) ) +!'*E!'*E%k2I )3uQi0$Q-(++7.=  _ 5()  >EI&GI&G$%78 %Y'y!+d237v?  {7)%< = >" B  JM[^_!  t J rSrxrw depends_onruzN/A [z] z name: z team: z depends_on: z task_file: uDDRY-RUN 완료: 실제 디스패치는 수행되지 않았습니다.rr)r\rr started_at steps_doneu9초기 상태 저장 완료: pipeline_id=%s first_step=%su파이프라인 'u' 시작 완료. 첫 스텝: u)WARNING: 첫 스텝 디스패치 실패: uWARNING: 파이프라인 'u'에 스텝이 없습니다.)r"r_r`rr+rrFileNotFoundErrorprintr/r rIr~r can_spendrV enumeraterrrrrrrr)r\rrrEr3validation_errorserrr ledger_pathrrirssidrSteamdepsr first_step_id initial_state first_steprs r4rrhs GGLL;-u0EFM KK3[A /*(3 57$ C D,  <<2L'',,~/UVK  %F   K 6 \]h\ijk Wb1E .{m5AB    Q/01 SZL,- c  * 3GAt((4-C88FC(D88M95D88L"-D!5u=I Cs"SE" # L' ( L' ( &tf- . %i[1 2 3 c  TV+0E!HLL&TM#%ll8<<0888EOOQ M ]3 KKK[Zgh 1X  KG  %k]2OP]_ ` =m_M N *;-7STUK  J=/Z[  6se<=s KL +L 3LL c tt}|js tdyt |j d}|s tdytdt |dt|D]x}|j}t|}|td|d,|jdd }|jd d }|jd d }td|d |d|d|ztt}|j} tdtdtd| ddd| ddd| ddt|jdz} td| ddy)uV--status: state/*.json 전체를 읽고 파이프라인 상태 요약을 출력한다.u.실행 중인 파이프라인이 없습니다.Nru=== 파이프라인 상태 (개) ===ru] (상태 파일 손상)rrwr-rz ] status=z current_step=z started_at=r}u=== 토큰 사용량 ===u오늘: rrrrz ( percentagez%)g?u경고 임계값: z (80%))rrarNrlistrrVsortedrrrIr rrintDAILY_HARD_LIMIT) r state_filesrgr\rirrrrsummary warning_limits r4rrs{iJ     >?zx01K  >? ([)9(:( CD[) h  oo ";/ = C }$<= > 8Y/yy5 YY|S1  K= & ~\ZdYefg h %F,,.G "I $% HWW%a(GG, > ?sA C C;C66C;c t|}t|}|r.tdt |d|D]}td|ytdy#t$r}td|Yd}~yd}~wwxYw)u--validate: YAML 파일을 로드하고 파이프라인 스키마를 검증한다. Args: yaml_path: 검증할 YAML 파일 경로. uERROR: YAML 로드 실패: Nz Invalid: u개 오류 발견z ERROR: u$Valid: 파이프라인 검증 통과)rr/rr rV)r7rEr3rrs r4rrs + x (F  #f+&789 %C IcU# $ % 45  +C512s A A5A00A5ctjdd}|jd}|jddd |jd d d |jddd |jddd |jddd |jdddd|j }|j r t y|jr"t|j|jy|jr ty|jr ty|jrt|jyy)uargparse 기반 CLI 진입점.z auto_orch.pyu:Auto Orchestrator — Phase 3 오케스트레이터 코어)prog descriptionT)requiredz--scan store_trueuU이벤트 스캔 및 대기 스텝 디스패치 (30초 주기 타이머에서 호출))actionhelpz--run PIPELINE_IDu*지정한 파이프라인을 수동 실행)metavarrz--statusu2현재 실행 중인 파이프라인 상태 출력z--listu'등록된 파이프라인 목록 출력z --validate YAML_PATHu"파이프라인 YAML 파일 검증z --dry-runFuV파이프라인을 검증하고 시뮬레이션만 수행 (실제 디스패치 없음))rdefaultr)rN)argparseArgumentParseradd_mutually_exclusive_group add_argument parse_argsscanrrrrrrrrvalidater)parsergroupargss r4mainr,sG  $ $ PF  / / / >E  d   9   A   6   1   e     D yy $,,/   T]]# rJ__main__)N)r N)F)D__doc__r"r'rdloggingr"rsysrrpathlibrtypingrrr=r~r_insertorchestrator.event_busrrorchestrator.pipeline_validatorr orchestrator.team_lockr orchestrator.token_ledgerr r$r`rarrrrrrrrr basicConfigDEBUG getLogger__name__r+__all__r rrrr@rrHrrrrrrrrrrrrrrr,rJr4r>s    ' '!HHOOA~&B=+1 ) GGLL)= >  ^[9 ggll>+EF ww||N,CD  ^-EF WW\\./ : 77<<0UV77<<0IJ!ggll>+QR  -- >   8 $  2Xc]. C D $ST4 /$ /4 /"c#$s)NCHTN@ BS B B$ B&3333t33vC4$;Z^@BB#B$BT=4:=Jo dRVRVtRVRVj8D?06C6D684$n zFrJ