gmakstutis/LightRAG
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Optimize log messages

Browse source
This commit is contained in:
yangdx 2025-04-30 13:53:03 +08:00
parent 946e55115d
commit 62fd4a0540
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lightrag/utils.py
View file

@ -346,7 +346,7 @@ def priority_limit_async_func_call(max_size: int, max_queue_size: int = 1000):
logger.error(f"limit_async: Critical error in worker: {str(e)}") logger.error(f"limit_async: Critical error in worker: {str(e)}")
await asyncio.sleep(0.1) # Prevent high CPU usage await asyncio.sleep(0.1) # Prevent high CPU usage
finally: finally:
logger.warning("limit_async: Worker exiting") logger.debug("limit_async: Worker exiting")
async def health_check(): async def health_check():
"""Periodically check worker health status and recover""" """Periodically check worker health status and recover"""
@ -379,7 +379,7 @@ def priority_limit_async_func_call(max_size: int, max_queue_size: int = 1000):
except Exception as e: except Exception as e:
logger.error(f"limit_async: Error in health check: {str(e)}") logger.error(f"limit_async: Error in health check: {str(e)}")
finally: finally:
logger.warning("limit_async: Health check task exiting") logger.debug("limit_async: Health check task exiting")
initialized = False initialized = False
async def ensure_workers(): async def ensure_workers():