wangbo/ComfyUI
1
0
Fork 0
mirror of https://github.com/comfyanonymous/ComfyUI.git synced 2026-03-06 09:47:35 +08:00
Code Issues Actions 23 Packages Projects Releases Wiki Activity

Add lifecycle logging to asset seeder

Browse Source 
Log pause, resume, cancel, and restart events

Amp-Thread-ID: https://ampcode.com/threads/T-019c4f56-3fe1-72cb-888a-3ac4ac99b3d7
Co-authored-by: Amp <amp@ampcode.com>
This commit is contained in:
Luke Mino-Altherr 2026-02-11 17:03:43 -08:00
parent b407a80d5a
commit 4f29877939
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/assets/seeder.py
View File

@ -198,6 +198,7 @@ class AssetSeeder:
with self._lock: with self._lock:
if self._state not in (State.RUNNING, State.PAUSED): if self._state not in (State.RUNNING, State.PAUSED):
return False return False
logging.info("Asset seeder cancelling (was %s)", self._state.value)
self._state = State.CANCELLING self._state = State.CANCELLING
self._cancel_event.set() self._cancel_event.set()
self._pause_event.set() # Unblock if paused so thread can exit self._pause_event.set() # Unblock if paused so thread can exit
@ -222,6 +223,7 @@ class AssetSeeder:
with self._lock: with self._lock:
if self._state != State.RUNNING: if self._state != State.RUNNING:
return False return False
logging.info("Asset seeder pausing")
self._state = State.PAUSED self._state = State.PAUSED
self._pause_event.clear() self._pause_event.clear()
return True return True
@ -235,6 +237,7 @@ class AssetSeeder:
with self._lock: with self._lock:
if self._state != State.PAUSED: if self._state != State.PAUSED:
return False return False
logging.info("Asset seeder resuming")
self._state = State.RUNNING self._state = State.RUNNING
self._pause_event.set() self._pause_event.set()
self._emit_event("assets.seed.resumed", {}) self._emit_event("assets.seed.resumed", {})
@ -262,6 +265,7 @@ class AssetSeeder:
Returns: Returns:
True if new scan was started, False if failed to stop previous True if new scan was started, False if failed to stop previous
""" """
logging.info("Asset seeder restart requested")
with self._lock: with self._lock:
prev_roots = self._roots prev_roots = self._roots
prev_phase = self._phase prev_phase = self._phase