From b8041c52a46ba9fc558b91da6256df553754cb00 Mon Sep 17 00:00:00 2001 From: appleb_m Date: Tue, 9 Jun 2026 14:26:06 +0200 Subject: [PATCH] CONFIG: forgot to commit changes to config redis handling! --- src/aare/daq/config.py | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/src/aare/daq/config.py b/src/aare/daq/config.py index 1932f5a0..17e3225f 100644 --- a/src/aare/daq/config.py +++ b/src/aare/daq/config.py @@ -894,18 +894,27 @@ class BeamlineConfig: else: self.__client.set(f"{self.__bl}:last_best_b_factor", last_best_b_factor) - def get_mount_fail_count(self) -> int: - value = self.__client.get(f"{self.__bl}:mount_fail_count") + def _mount_failure_streak_key(self) -> str: + return f"{self.__bl}:mount_fail_count" + + def get_mount_failure_streak(self) -> int: + value = self.__client.get(self._mount_failure_streak_key()) return int(value) if value else 0 + def increment_mount_failure_streak(self) -> int: + return int(self.__client.incr(self._mount_failure_streak_key())) + + def reset_mount_failure_streak(self) -> None: + self.__client.delete(self._mount_failure_streak_key()) + + def get_mount_fail_count(self) -> int: + return self.get_mount_failure_streak() + def record_mount_failure(self) -> int: - # Atomic increment - return self.__client.incr(f"{self.__bl}:mount_fail_count") + return self.increment_mount_failure_streak() def record_mount_success(self): - # Atomic delete/reset - self.__client.delete(f"{self.__bl}:mount_fail_count") - + self.reset_mount_failure_streak() @property def simple_input_parameters(self) -> SimpleStrategyInputModel | None: tmp = self.__client.get(f"{self.__bl}:simple_input_params")