From 5a393e563e8dca8593bc5def8bb538d1d6e7e5b6 Mon Sep 17 00:00:00 2001 From: yangdx Date: Mon, 28 Apr 2025 18:37:51 +0800 Subject: [PATCH] remove duplicate priority setting for merge summerization --- lightrag/operate.py | 1 - lightrag/utils.py | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/lightrag/operate.py b/lightrag/operate.py index d10cb2c2..13c40cf4 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -147,7 +147,6 @@ async def _handle_entity_relation_summary( llm_response_cache=llm_response_cache, max_tokens=summary_max_tokens, cache_type="extract", - priority=5, # Higher priority for entity/relation summary ) return summary diff --git a/lightrag/utils.py b/lightrag/utils.py index 1cbe383c..783800fb 100644 --- a/lightrag/utils.py +++ b/lightrag/utils.py @@ -308,7 +308,7 @@ def priority_limit_async_func_call(max_size: int): """Worker that processes tasks from the priority queue""" while True: # Get task from queue (priority, task_id, future, args, kwargs) - priority, _, future, args, kwargs = await queue.get() + _, _, future, args, kwargs = await queue.get() try: # Execute the function result = await func(*args, **kwargs)