wangbo/ComfyUI
1
0
Fork 0
mirror of https://github.com/comfyanonymous/ComfyUI.git synced 2026-01-25 13:50:15 +08:00
Code Issues Actions 15 Packages Projects Releases Wiki Activity

Update comment

Browse Source
This commit is contained in:
doctorpangloss 2024-02-08 21:15:58 -08:00
parent d5bcaa515c
commit b3f1ce7ef0
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
comfy/cmd/main.py
View File

@ -255,11 +255,11 @@ async def main():
hijack_progress(server) hijack_progress(server)
cuda_malloc_warning() cuda_malloc_warning()
# in a distributed setting, the prompt worker will not be able to send execution events via the websocket # in a distributed setting, the default prompt worker will not be able to send execution events via the websocket
# the distributed prompt queue will be responsible for simulating those events until the broker is configured to
# pass those messages to the appropriate user
worker_thread_server = server if not distributed else ServerStub() worker_thread_server = server if not distributed else ServerStub()
if "worker" in args.distributed_queue_roles: if "worker" in args.distributed_queue_roles:
logging.warning(
f"Distributed workers started in the default thread loop cannot notify clients of progress updates. Instead of comfyui or main.py, use comfyui-worker.")
threading.Thread(target=prompt_worker, daemon=True, args=(q, worker_thread_server,)).start() threading.Thread(target=prompt_worker, daemon=True, args=(q, worker_thread_server,)).start()
# server has been imported and things should be looking good # server has been imported and things should be looking good