j_ DUdZddlZddlZddlmZmZej eZiZ ee ejfe d<ejZde dejdefdZde ddfd Zde defd ZiZee e fe d <dd e d e defdZd e ddfdZd e dee fdZdefdZy)u`백그라운드 태스크 레지스트리 — 활성 태스크 추적 + 시작 시 stale 복구.N)DictOptional _active_taskstask_keythreadreturnct5tj|}|r|jr dddy|t|< dddy#1swYyxYw)u7태스크 등록. 이미 실행 중이면 False 반환.NFT_lockrgetis_alive)rrexistings L/Users/manta/Documents/Projects/TheRoad-I1/backend/app/core/task_registry.py register_taskr sF  $$X. ))+ #) h s)A  A  Acft5tj|ddddy#1swYyxYwN)r rpop)rs runregister_taskrs (D) '0ct5tj|}|duxr|jcdddS#1swYyxYwrr )rts ris_task_runningrs1    h '}- s +<A_episode_claims episode_keyholdercrt5|tvr dddy|t|< dddy#1swYyxYw)u에피소드 하나에 배치 하나 — 잡았으면 True, 이미 남이 잡았으면 False. 검사와 잡기를 **한 자물쇠 안에서** 한다. 나눠 놓으면 그 사이가 곧 틈이다. NFT)r r)rrs rclaim_episode_runr0s2  / ) (. $ s - -6cft5tj|ddddy#1swYyxYwr)r rrrs rrelease_episode_runr <s K. rcdt5tj|cdddS#1swYyxYwr)r rr rs repisode_run_holderr"As "";/ s&/cddlm}|j|j|jdk(j ddd}|j |S)uH시작 시 running 상태로 남은 PipelineProgress를 error로 복구.r)PipelineProgressrunningerrorz!Server restarted during operation)status error_message)app.models.projectr$queryfilterr'updatecommit) db_sessionr$counts rrecover_stale_progressr0FsU3   - . 5 59,  f2U VW  L))__doc__logging threadingtypingrr getLogger__name__loggerrstrThread__annotations__Lockr boolrrrrrr r"intr0r1rrAsf!   8 $-/ tC)))*/ C)9)9d*c*d* .c.d.$#%c3h$ 3  T /S/T/ 0C0HSM0 #r1