Merge pull request #1531 from unclecode/develop

Marketplace and brand book changes
This commit is contained in:
Nasrin
2025-10-03 13:24:51 +08:00
committed by GitHub
30 changed files with 9543 additions and 7 deletions

View File

@@ -455,8 +455,6 @@ class MemoryAdaptiveDispatcher(BaseDispatcher):
# Update priorities for waiting tasks if needed
await self._update_queue_priorities()
return results
except Exception as e:
if self.monitor:
@@ -467,6 +465,7 @@ class MemoryAdaptiveDispatcher(BaseDispatcher):
memory_monitor.cancel()
if self.monitor:
self.monitor.stop()
return results
async def _update_queue_priorities(self):
"""Periodically update priorities of items in the queue to prevent starvation"""