From 427e821b6dae28c9260e5d5da70a45d6bc986703 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Fri, 19 Sep 2025 22:07:45 +0200 Subject: [PATCH] fix(reforcexy): ensure thread safety everywhere MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- ReforceXY/user_data/freqaimodels/ReforceXY.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/ReforceXY/user_data/freqaimodels/ReforceXY.py b/ReforceXY/user_data/freqaimodels/ReforceXY.py index 0c94c5a..86fdbef 100644 --- a/ReforceXY/user_data/freqaimodels/ReforceXY.py +++ b/ReforceXY/user_data/freqaimodels/ReforceXY.py @@ -7,7 +7,6 @@ import warnings from collections import defaultdict from collections.abc import Mapping from enum import IntEnum -from functools import lru_cache from pathlib import Path from statistics import stdev from typing import Any, Callable, Dict, Literal, Optional, Tuple, Type, Union @@ -2179,7 +2178,6 @@ def deepmerge(dst: Dict[str, Any], src: Dict[str, Any]) -> Dict[str, Any]: return dst_copy -@lru_cache(maxsize=128) def linear_schedule(initial_value: float) -> Callable[[float], float]: def func(progress_remaining: float) -> float: return progress_remaining * initial_value @@ -2187,7 +2185,6 @@ def linear_schedule(initial_value: float) -> Callable[[float], float]: return func -@lru_cache(maxsize=128) def _compute_gradient_steps(tf: int, ss: int) -> int: if tf > 0 and ss > 0: return min(tf, max(tf // ss, 1)) @@ -2208,7 +2205,6 @@ def compute_gradient_steps(train_freq: Any, subsample_steps: Any) -> int: return -1 -@lru_cache(maxsize=32) def hours_to_seconds(hours: float) -> float: """ Converts hours to seconds @@ -2217,7 +2213,6 @@ def hours_to_seconds(hours: float) -> float: return seconds -@lru_cache(maxsize=32) def steps_to_days(steps: int, timeframe: str) -> float: """ Calculate the number of days based on the given number of steps -- 2.43.0