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

Increase timeout buffers for async function calls

Browse source 
• Extend execution timeout buffer to 150s
• Extend task duration buffer to 180s
• Account for low-level retry delays
• Improve health check phase handling
• Reduce timeout-related failures
This commit is contained in:
yangdx 2025-09-06 23:56:24 +08:00
parent 725db3b240
commit c87eb2cfcf
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lightrag/utils.py
View file

@ -473,12 +473,12 @@ def priority_limit_async_func_call(
nonlocal max_execution_timeout, max_task_duration nonlocal max_execution_timeout, max_task_duration
if max_execution_timeout is None: if max_execution_timeout is None:
max_execution_timeout = ( max_execution_timeout = (
llm_timeout + 30 llm_timeout + 150
) # LLM timeout + 30s buffer for network delays ) # LLM timeout + 150s buffer for low-level retry
if max_task_duration is None: if max_task_duration is None:
max_task_duration = ( max_task_duration = (
llm_timeout + 60 llm_timeout + 180
) # LLM timeout + 1min buffer for execution phase ) # LLM timeout + 180s buffer for health check phase
queue = asyncio.PriorityQueue(maxsize=max_queue_size) queue = asyncio.PriorityQueue(maxsize=max_queue_size)
tasks = set() tasks = set()