remove duplicate priority setting for merge summerization

This commit is contained in:
yangdx
2025-04-28 18:37:51 +08:00
parent 140b1b3cbb
commit 5a393e563e
2 changed files with 1 additions and 2 deletions

View File

@@ -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)