extern/easydiffusion
1
0
Fork 1
mirror of https://github.com/easydiffusion/easydiffusion.git synced 2025-06-16 23:07:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

LoadingModel detection

Browse Source
This commit is contained in:
Marc-Andre Ferland 2022-10-14 06:03:18 -04:00
parent 4a7260b1be
commit 6ae3b77c2f
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ui/server.py
View File

@ -162,16 +162,16 @@ def preload_model(file_path=None):
print(traceback.format_exc()) print(traceback.format_exc())
def thread_render(): def thread_render():
global current_state, current_state_error global current_state, current_state_error, current_model_path
from sd_internal import runtime from sd_internal import runtime
current_state = ServerStates.Online current_state = ServerStates.Online
preload_model() preload_model()
while True: while True:
task_cache.clean() task_cache.clean()
task = None
if isinstance(current_state_error, SystemExit): if isinstance(current_state_error, SystemExit):
current_state = ServerStates.Unavailable current_state = ServerStates.Unavailable
return return
task = None
try: try:
task = tasks_queue.get(timeout=1) task = tasks_queue.get(timeout=1)
except queue.Empty as e: except queue.Empty as e:
@ -185,10 +185,13 @@ def thread_render():
task.error = current_state_error task.error = current_state_error
continue continue
print(f'Session {task.request.session_id} starting task {id(task)}') print(f'Session {task.request.session_id} starting task {id(task)}')
current_state = ServerStates.Rendering
try: try:
task.lock.acquire(blocking=False) task.lock.acquire(blocking=False)
res = runtime.mk_img(task.request) res = runtime.mk_img(task.request)
if current_model_path == task.request.use_stable_diffusion_model:
current_state = ServerStates.Rendering
else:
current_state = ServerStates.LoadingModel
except Exception as e: except Exception as e:
task.error = e task.error = e
task.lock.release() task.lock.release()
@ -199,6 +202,9 @@ def thread_render():
if task.request.stream_progress_updates: if task.request.stream_progress_updates:
dataQueue = task.buffer_queue dataQueue = task.buffer_queue
for result in res: for result in res:
if current_state == ServerStates.LoadingModel:
current_state = ServerStates.Rendering
current_model_path = task.request.use_stable_diffusion_model
if isinstance(current_state_error, SystemExit) or isinstance(current_state_error, StopAsyncIteration) or isinstance(task.error, StopAsyncIteration): if isinstance(current_state_error, SystemExit) or isinstance(current_state_error, StopAsyncIteration) or isinstance(task.error, StopAsyncIteration):
runtime.stop_processing = True runtime.stop_processing = True
if isinstance(current_state_error, StopAsyncIteration): if isinstance(current_state_error, StopAsyncIteration):