mirror of
https://github.com/sunnypilot/sunnypilot.git
synced 2026-09-29 19:23:41 +08:00
Update param_watcher.py
This commit is contained in:
committed by
GitHub
parent
9d87beac8e
commit
264948e5ff
@@ -55,10 +55,7 @@ class ParamWatcher(Params):
|
||||
if bucket:
|
||||
to_refresh.append((k, list(bucket.keys())))
|
||||
|
||||
# Regenerate cache for previously cached keys
|
||||
if to_refresh:
|
||||
# Small sleep to ensure FS is ready if needed
|
||||
time.sleep(0.01)
|
||||
for key, sigs in to_refresh:
|
||||
for sig in sigs:
|
||||
try:
|
||||
@@ -69,9 +66,6 @@ class ParamWatcher(Params):
|
||||
except Exception:
|
||||
cloudlog.exception(f"ParamWatcher: Failed to regenerate {key} {sig}")
|
||||
|
||||
if path in ["GithubRunnerSufficientVoltage", "NetworkMetered"]:
|
||||
return
|
||||
|
||||
for callback in self._callbacks:
|
||||
try:
|
||||
callback(path, mask)
|
||||
@@ -92,7 +86,6 @@ class ParamWatcher(Params):
|
||||
with self._lock:
|
||||
current_version = self._version.get(k, 0)
|
||||
if current_version != start_version:
|
||||
# Version changed during fetch, fetch again to get latest
|
||||
val = getter()
|
||||
self._cache.setdefault(k, {})[sig] = (self._version.get(k, 0), val)
|
||||
return val
|
||||
|
||||
Reference in New Issue
Block a user