wangbo/ComfyUI-Manager
1
0
Fork 0
mirror of https://github.com/Comfy-Org/ComfyUI-Manager.git synced 2026-07-12 17:37:06 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

perf(cnr): optimize event loop blocking with asyncio.sleep and fix parameter encoding in fetch_all

Browse Source
This commit is contained in:
craftingmod 2026-06-30 06:29:17 +09:00
parent 62fd58524f
commit 9a0b2c40f1
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
glob/cnr_utils.py
View File

@ -5,6 +5,7 @@ import platform
import time import time
from dataclasses import dataclass from dataclasses import dataclass
from typing import List from typing import List
from urllib.parse import urlencode
import logging import logging
import manager_core import manager_core
@ -137,9 +138,15 @@ async def _get_cnr_data(sync_mode=None, dont_wait=True, **kwargs):
nodes_map = dict(existing_nodes) nodes_map = dict(existing_nodes)
while remained: while remained:
sub_uri = f'{base_url}/nodes?page={page}&limit=30&comfyui_version={comfyui_ver}&form_factor={form_factor}' params = {
'page': page,
'limit': 30,
'comfyui_version': comfyui_ver,
'form_factor': form_factor,
}
if timestamp_filter: if timestamp_filter:
sub_uri += f'&timestamp={timestamp_filter}' params['timestamp'] = timestamp_filter
sub_uri = f'{base_url}/nodes?{urlencode(params)}'
sub_json_obj = await asyncio.wait_for( sub_json_obj = await asyncio.wait_for(
manager_util.get_data_with_cache(sub_uri, cache_mode=False, silent=True, dont_cache=True), manager_util.get_data_with_cache(sub_uri, cache_mode=False, silent=True, dont_cache=True),
@ -154,7 +161,7 @@ async def _get_cnr_data(sync_mode=None, dont_wait=True, **kwargs):
logging.info(f"[ComfyUI-Manager] FETCH ComfyRegistry Data: {page}/{sub_json_obj['totalPages']}") logging.info(f"[ComfyUI-Manager] FETCH ComfyRegistry Data: {page}/{sub_json_obj['totalPages']}")
page += 1 page += 1
time.sleep(0.5) await asyncio.sleep(0.5)
logging.info(f"[ComfyUI-Manager] FETCH ComfyRegistry Data [DONE]") logging.info(f"[ComfyUI-Manager] FETCH ComfyRegistry Data [DONE]")