diff --git a/sunnypilot/common/tests/test_param_watcher.py b/sunnypilot/common/tests/test_param_watcher.py index 60fdd8cad7..2579530748 100644 --- a/sunnypilot/common/tests/test_param_watcher.py +++ b/sunnypilot/common/tests/test_param_watcher.py @@ -6,7 +6,7 @@ import tracemalloc from openpilot.common.params import Params from openpilot.common.params_pyx import UnknownKeyName -from openpilot.sunnypilot.common.param_watcher import ParamWatcher +from openpilot.sunnypilot.common.param_watcher import ParamWatcher, IN_MODIFY class TestParamWatcher: @@ -82,10 +82,11 @@ class TestParamWatcher: def test_cache_invalidation_simulation(self, param_watcher): self.params.put(self.bytes_key, b"old") assert param_watcher.get(self.bytes_key) == b"old" + time.sleep(0.2) event = threading.Event() param_watcher.add_watcher(lambda key, mask: event.set()) - param_watcher._trigger_callbacks(self.bytes_key, 0) # mask=0 for simulation + param_watcher._trigger_callbacks(self.bytes_key, IN_MODIFY) assert event.wait(timeout=2), "Callback not triggered" self.params.put(self.bytes_key, b"new")