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)