From 261e17c4d6ad7a015e7a1e4e36f0fa6e97a6df73 Mon Sep 17 00:00:00 2001 From: wakonig_k Date: Tue, 16 Jun 2026 16:21:00 +0200 Subject: [PATCH] fix: update default maxlen for ScanStorage to 10 --- bec_lib/bec_lib/scan_items.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/bec_lib/bec_lib/scan_items.py b/bec_lib/bec_lib/scan_items.py index 51cc6f3b2..e5478d42b 100644 --- a/bec_lib/bec_lib/scan_items.py +++ b/bec_lib/bec_lib/scan_items.py @@ -258,11 +258,11 @@ class ScanStorage: Args: scan_manager: The scan manager that will use this storage. - maxlen: Maximum number of scan items to store (default: 100). + maxlen: Maximum number of scan items to store (default: 10). init_scan_number: Initial scan number to start from (default: 0). """ - def __init__(self, scan_manager: ScanManager, maxlen=100, init_scan_number=0) -> None: + def __init__(self, scan_manager: ScanManager, maxlen=10, init_scan_number=0) -> None: self.scan_manager = scan_manager self.storage = deque(maxlen=maxlen) self.last_scan_number = init_scan_number @@ -504,7 +504,7 @@ def update_with_queue_status(self, queue_msg: messages.ScanQueueStatusMessage): This method is thread-safe and processes queue status messages to create ScanItem instances for any scans that don't already exist in storage. It limits processing - to the most recent 20 queue items to avoid excessive memory usage. + to the most recent 5 queue items to avoid excessive memory usage. Args: queue_msg(messages.ScanQueueStatusMessage): The queue status message containing scan info. @@ -526,7 +526,7 @@ def update_with_queue_status(self, queue_msg: messages.ScanQueueStatusMessage): scan_id=queue_item.scan_id[scan_idx], # type: ignore[index] status=queue_item.status, # type: ignore[attr-defined] ) - if ii > 20: - # only keep the last 20 queue items in storage to avoid + if ii > 5: + # only keep the last 5 queue items in storage to avoid # evicting too many items just because of a large queue break