&원자적으로 이벤트를 소비한다. 성공 시 True, 이미 소비됨/거부 시 False. Args: incoming_dir: 미처리 이벤트 파일이 위치한 디렉터리 경로. processed_dir: 처리 완료된 이벤트 파일을 이동할 디렉터리 경로. event_file: 이벤트 파일 이름 (디렉터리 구분자 없는 순수 파일명). Returns: True — 이 프로세스가 이벤트를 성공적으로 소비함. False — 이미 다른 프로세스가 선점했거나, 보안 거부(symlink), 기타 오류. uN보안 거부: '%s' 는 symlink입니다. 이벤트 소비를 건너뜁니다.FTud이벤트 파일 '%s' 을 찾을 수 없습니다. 다른 프로세스가 이미 소비했습니다.u8이벤트 소비 중 OS 오류 발생 (파일: '%s'): %sN) ospathjoinislinkloggerwarningrenameFileNotFoundErrorinfoOSErrorerror)rrrsrc_pathdst_pathexcs G/home/jay/workspace/.worktrees/task-2057-dev2/orchestrator/event_bus.pyrrsww||L*5Hww||M:6H ww~~hgiqr (H%  r    OQY[^_s8BC0C8CC events_dircntjj|sgSg}tj|D]x}|j}|j dst jd|8|jr!t jd|jitjjtjj||rt jd|tjjtjj||rt jd|tjj||}tj|j|t jd||j|{|S)uqmemory/events/*.done 파일을 스캔하여 incoming/으로 복사한다. Layer 2↔3 통합의 핵심: .done 파일 원본을 보존하면서 incoming/으로 복사하여 auto_orch.py가 파이프라인 트리거를 평가할 수 있게 한다. Args: events_dir: .done 파일이 생성되는 원본 디렉토리 (memory/events/) incoming_dir: 미처리 이벤트 복사 대상 디렉토리 (orchestrator/incoming/) processed_dir: 처리 완료된 이벤트 디렉토리 (orchestrator/processed/) Returns: 이번 호출에서 새로 복사된 이벤트 파일명 목록 z.doneuF패턴 불일치: '%s' 는 .done으로 끝나지 않음 — 건너뜀.uN보안 거부: '%s' 는 symlink입니다. scan_done_events가 건너뜁니다.u?중복 건너뜀: '%s' 가 이미 incoming/에 존재합니다.u@중복 건너뜀: '%s' 가 이미 processed/에 존재합니다.u=이벤트 파일 '%s' 을 incoming/으로 복사했습니다.)r r isdirscandirnameendswithrdebug is_symlinkrexistsr shutilcopy2rappend)rrrcopiedentryfnamers rrr8s: 77== $ FJ' ~~g& LLach i      NN`    77>>"'',,|U; < LLZ\a b  77>>"'',,}e< = LL[]b c 77<< e4 UZZ* SUZ[ e;> M) __doc__loggingr r"__all__ getLogger__name__rstrboolrlistrr(rr2s| . /   8 $""C"S"T"J22C22PTUXPY2r(