:ig3fUdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZej j#ddZd ed <Gd d e Zdd ZddZddZddZdZddZ d dZdddd d!dZd"dZd#dZedk(reyy)$uo모션 카드뉴스 렌더 큐 (파일 기반 작업 큐). IDS Phase 5 — HTML→MP4 모션 카드뉴스 백그라운드 처리 큐 - 파일 기반 작업 큐 (/tmp/motion_render_queue/ 또는 MOTION_QUEUE_DIR 환경변수) - ThreadPoolExecutor 기반 병렬 처리 (기본 max_concurrent=2) - 자동 재시도 (기본 max_retries=2) - 작업 타임아웃 처리 - CLI: python3 motion_render_queue.py --process [--max-concurrent N] 사용 예시: # 작업 큐에 추가 job_id = enqueue({ "frame_paths": ["/path/to/frame1.png", "/path/to/frame2.png"], "output_path": "/path/to/output.mp4", "size": [1080, 1080], "effect": "fade", "fps": 30, "duration_per_frame": 1.5, "bgm_path": None, }) # 큐 처리 summary = process_queue(max_concurrent=2, timeout_per_job=120, max_retries=2) print(summary) ) annotationsN)ThreadPoolExecutor)Enum)PathMOTION_QUEUE_DIRz/tmp/motion_render_queuestr_DEFAULT_QUEUE_DIRc$eZdZdZdZdZdZdZdZy) JobStatusu작업 상태 열거형.PENDINGRUNNINGSUCCESSFAILEDTIMEOUTN) __name__ __module__ __qualname____doc__r r rrrL/home/jay/workspace/.worktrees/task-2459-dev5/scripts/motion_render_queue.pyr r *s"GGG FGrr cttjjdt}|j dd|dz j d|S)uB큐 디렉토리 경로를 반환하고 없으면 생성합니다.rT)parentsexist_okjobs)r)rosenvirongetr mkdir) queue_dirs r_get_queue_dirr!4sIRZZ^^$68JKLI OOD4O0- rc,ttj}t}i||tj j tjdd}|dz |dz }|jtj|td|S)u작업을 큐에 추가합니다. Args: job: 작업 딕셔너리. 필수 키: frame_paths, output_path, size, effect, fps, duration_per_frame, bgm_path Returns: 고유 작업 ID (UUID4 문자열) r)job_idstatus created_at retry_countr.jsondefaultutf-8encoding) ruuiduuid4r!r r valuetime write_textjsondumps)jobr#r job_datajob_files renqueuer7<s F I ##))iik H6!vhe$44H  8S9GL MrcLtj|jdS)u!작업 파일을 로드합니다.r*r+)r2loads read_text)r6s r _load_jobr;Ws ::h(('(: ;;rc||d}|dz |dz }|jtj|tdy)u+작업 상태를 파일에 저장합니다.r#rr'r(r*r+N)r1r2r3r)r5r r#r6s r _save_jobr=\s@ h F6!vhe$44H  8S9GLrcddlm}ddl}ttj j dz dz }d}|dz|j vr|j |dzjSdD]}|d|}||j vs|j|||d z }| |j Jd |d ||j|}||_ ||j |< |jj|||j vr||j||d z t|g }| |j Jd||j|} || _ | |j |< |jj| |j |djS#t$r|j |=wxYw#t$r|j |=wxYw)urender_motion 함수를 동적으로 로드합니다. 하이픈이 포함된 스킬 패키지명(motion-cardnews-ko)을 처리합니다. rNskillszmotion-cardnews-komotion_cardnews_koz.render)sizeseffectsframesrenderocrbgm.z.pyzfailed to load submodule z from z __init__.py)submodule_search_locationszfailed to load package )importlib.utilutilsysr__file__parentmodules render_motionspec_from_file_locationloadermodule_from_spec __package__ exec_module Exceptionr) _ilurK skill_dirpkg_namesubmodmod_namespecmod init_specpkg_mods r_get_render_motionr_cs "X%%,,x7:NNI#H)s{{*{{8i/0>>>IZq) 3;; &//vhcN*D# (? vC\]c\ddjktjuAv v?''-C&CO$'CKK !  '',$s{{"00   %(+I'71 $)9)9)EkI`ai`jGkkE'' 2& ' H     ( ( 1 ;;(7+ , : ::+ KK) "  H%  sF%F7F47Gc t}|jdgDcgc] }t|}}t|jdd}|jdddg}t|tt fr+t |dk\rt|dt|df}nd }|jd d }|r t|nd }||||t|jd d t|jddt|jdd|} tjj|d<tj|d<| } |Scc}w)ub단일 작업을 실행합니다. Returns: 업데이트된 job_data 딕셔너리 frame_paths output_pathz output.mp4size8r)rdrdbgm_pathNeffectfadefpsduration_per_frameg?)rarbrcrhrjrlrgr$ completed_at)r_rr isinstancelisttuplelenintrfloatr rr/r0) r5rOprarbsize_rawrcbgm_rawrgresult_s r _execute_jobrys6 '(M$,LL$CDq47DKDx||M<@AK||FT4L1H(T5M*s8}/AHQK #hqk"23ll:t,G 'tG}TH  8<<&12  UB' ( .BC!HIF#**00HX#yy{H^A O3EsEcR d}d}||krtjjd<t|dg}g g d fd } t j | d} | j | j|| jrsd|d<tjjd<d |d d <t||5|jd dd z|d <|jddd z|d<dddy rR d} t| ||5|jddd z|d<|dkDr|jdd|z|d<dddy rt d}nd}|d z }|d<|d<||kr#|5|jddd z|d<ddd||krtjjd<|d<t||5|jddd z|d<dddy#1swYyxYw#1swYyxYw#1swYzxYw#1swYyxYw)u단일 작업을 재시도 로직과 함께 직접 실행합니다 (스레드 내에서 호출). 타임아웃은 threading.Timer로 구현합니다. summary 접근은 lock으로 보호합니다. rr$Fc tt}j|y#t$r}j|Yd}~yd}~wwxYw)N)rydictappendrU)updatede exc_holderr5 result_holders rworkerz#_run_job_with_retry..workersE %&tH~6$$W- %!!!$$ %s%) A AA T)targetdaemontimeoutu타임아웃 (u초)errorrrffailedNsuccess retry_totalu알 수 없는 오류r& last_errorreturnNone) r r r/r= threadingThreadstartjoinis_aliverrrr)r5r timeout_per_job max_retriessummarylockr&r timed_outrt updated_jobrrs` @@r_run_job_with_retryrsjKJ  $&..44(I&G $& &(  %   F4 8   ' ::<IaL!*!2!2!8!8HX "00A FHW  h * A%,[[A%>%B "$+KK!$%B "?-4[[-J[-XGM* Y  Z]+J0Jq "-!+ + % K)0]A)F)J & Kk  $r#))//HX'H\ h " 9#KK!4q899C A   Y  K K99s01G96H?HH9HHHH&rexmax_concurrentrrc 0t}t|dz jd}g}|D]K} t|}|j dt j jk(r|j|Mt|ddddtjd} |s| S|D]+}t j j|d<t#||-t%j&} t)| 5} |Dcgc]}| j+t,||||| | } }| D]} | j/||d zz  ddd| S#t$r5}tjd|jd|tYd}~Rd}~wwxYwcc}w#1swY| SxYw) u큐의 모든 PENDING 작업을 처리합니다. Args: max_concurrent: 동시 처리할 최대 작업 수 (ThreadPoolExecutor max_workers) timeout_per_job: 작업당 최대 대기 시간(초) max_retries: 실패 시 최대 재시도 횟수 Returns: 처리 요약 딕셔너리: { "total": int, "success": int, "failed": int, "timeout": int, "retry_total": int, } r*.jsonr$u작업 파일 로드 실패 (z): Nr)totalrrrr started_at) max_workersrer)r!sortedglobr;rr r r/r~rUwarningswarnname UserWarningrqr0r r=rLockrsubmitrrw)rrrr job_files pending_jobsjfjdrrrexecutorfuturesfs r process_queuer s. I F*00:;I!LX X2Bvvh9#4#4#:#::##B' X\"iik G ! ((..8 "i ! >> D  7B8#   OO#      BA HH_ a@H A BB NM X MM9"''#aSI; W W X.  B Ns6AE2F 7"F!F  F*E>>FF  Fct}g}t|dz jdD]} |jt ||S#t $rY-wxYw)u/큐의 모든 작업 상태를 반환합니다.rr)r!rrr~r;rU)r rrs r list_jobsrUsc IDi&(..x89  KK " & K   sA  AAc tjdtjd}|jddd|jddd |jd td d d |jdtddd|jdtd d|jdt dddt d|j}|jr|jtjd<|jrdt}|s tdy|D]F}td|jddd |jd!d"d#|jd$d"Hy|jrztd%|j d&t#|j |j$|j&'}td(|j)D]\}}td)|d*|y|j+y)+uCLI 진입점.u(모션 카드뉴스 렌더 큐 처리기u 사용 예시: # 큐 처리 (기본 설정) python3 motion_render_queue.py --process # 병렬 워커 수 지정 python3 motion_render_queue.py --process --max-concurrent 4 # 작업 목록 조회 python3 motion_render_queue.py --list ) descriptionformatter_classepilogz --process store_trueu)큐의 PENDING 작업을 처리합니다.)actionhelpz--listu/큐의 모든 작업 상태를 출력합니다.z--max-concurrentreNu1동시 처리할 최대 작업 수 (기본값: 2))typer)metavarrz --timeoutrSECu,작업당 타임아웃(초) (기본값: 120)z --max-retriesu&최대 재시도 횟수 (기본값: 2))rr)rz --queue-dirNDIRu$큐 디렉토리 경로 (기본값: )ru큐가 비어있습니다.[r$?z] r#r{u — rbu"큐 처리 시작 (max_concurrent=z)...ru처리 완료:z z: )argparseArgumentParserRawDescriptionHelpFormatter add_argumentrrrr parse_argsr rrrorprintrprocessrrrritems print_help)parserargsrrrwkvs rmainras  $ $> <<  F  L?jk rs!2#  1**..);=WXCX6< M2;j!HM9M9M9M9 M9  M9  M9 M9d FFF F  FR 5p zFr