diff --git a/B03_FileInput/B03_FileInput_Router.py b/B03_FileInput/B03_FileInput_Router.py index 94bb5b56..1ee99b67 100644 --- a/B03_FileInput/B03_FileInput_Router.py +++ b/B03_FileInput/B03_FileInput_Router.py @@ -132,16 +132,27 @@ def _write_stage_metadata( ) +# 실행 중인 백그라운드 작업의 강한 참조. 이벤트 루프는 작업을 약한 참조로만 들고 있어, +# 여기서 붙잡지 않으면 GC가 대기 중인 작업을 통째로 회수해 WF1 분석이 조용히 사라진다 +# (업로드는 성공·stage 0은 COMPLETE인데 stage 1은 NOT_STARTED로 남는 증상). +_BACKGROUND_TASKS: set[asyncio.Task] = set() + + def _schedule_background_task(coro: Any, *, task_name: str) -> None: task = asyncio.create_task(coro, name=task_name) + _BACKGROUND_TASKS.add(task) def _log_task_failure(completed: asyncio.Task) -> None: + _BACKGROUND_TASKS.discard(completed) try: completed.result() + except asyncio.CancelledError: + logger.warning("백그라운드 작업 취소됨: %s", task_name) except Exception: logger.exception("백그라운드 작업 실패: %s", task_name) task.add_done_callback(_log_task_failure) + logger.info("백그라운드 작업 시작: %s", task_name) async def _get_project_notification_info( diff --git a/B03_FileInput/B03_FileInput_UI_Page.ts b/B03_FileInput/B03_FileInput_UI_Page.ts index ff49b79d..85686106 100644 --- a/B03_FileInput/B03_FileInput_UI_Page.ts +++ b/B03_FileInput/B03_FileInput_UI_Page.ts @@ -244,10 +244,14 @@ export async function renderB03FileInput(root: HTMLElement): Promise { function onFileSelected(files: readonly File[], targetSlot?: FileSlot): void { if (files.length === 0) return; - if (selectedStates().length + files.length > UPLOAD_MAX_FILES) { + // 이미 고른 슬롯을 다시 고르는 것은 "교체"라 총 개수가 늘지 않는다 — 그 슬롯을 빼고 센다. + // (빼지 않으면 5개를 다 고른 뒤 하나만 바꾸려 할 때 개수 초과로 막힌다.) + const occupied = selectedStates().filter((state) => state.slot !== targetSlot).length; + if (occupied + files.length > UPLOAD_MAX_FILES) { pageError.textContent = L("B03_File_Error_Count"); return; } + pageError.textContent = ""; void (async () => { for (const file of files) await assignFileToSlot(file, targetSlot); await detectPausedUploads();