Skip to content

Commit 1bfd51b

Browse files
committed
fix: guard BoundedMemorySaver eviction loop against desync
Prevent infinite loop if _insertion_order empties before storage shrinks below max_threads due to external deletions.
1 parent 710f9f3 commit 1bfd51b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

apps/agent/src/bounded_memory_saver.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ def put(self, config, checkpoint, metadata, new_versions):
4343

4444
result = super().put(config, checkpoint, metadata, new_versions)
4545

46-
while len(self.storage) > self.max_threads:
46+
while len(self.storage) > self.max_threads and self._insertion_order:
4747
oldest_thread, _ = self._insertion_order.popitem(last=False)
4848
if oldest_thread in self.storage:
4949
logger.info(

0 commit comments

Comments
 (0)