fix(#5047): prevent sync refresh follower hangs
This commit is contained in:
1 parent
4f2bcada31
commit
6649db7041
2 files changed
+53
-1
No files matched your search
+1
-1
@@ -6897,7 +6897,7 @@ def get_available_models(*, prefer_cache: bool = False, force_refresh: bool = Fa
|
||||
# rebuild instead of giving up after 60s and duplicating it.
|
||||
wait_timeout = None
|
||||
_cache_build_cv.wait_for(
|
||||
lambda: not _cache_build_in_progress and _available_models_cache is not None,
|
||||
lambda: not _cache_build_in_progress,
|
||||
timeout=wait_timeout
|
||||
)
|
||||
cached = _get_fresh_memory_models_cache(time.monotonic())
|
||||
|
||||
@@ -235,6 +235,58 @@ def test_force_refresh_sync_followers_wait_past_legacy_timeout(tmp_path, monkeyp
|
||||
assert None in timeout_waits
|
||||
assert 60.0 not in timeout_waits
|
||||
|
||||
def test_force_refresh_sync_followers_retry_after_failed_active_rebuild(tmp_path, monkeypatch):
|
||||
import api.config as cfg
|
||||
import threading
|
||||
|
||||
_reset_models_memory_cache(monkeypatch)
|
||||
stale_catalog = _catalog("stale-model")
|
||||
rebuilt_catalog = _catalog("rebuilt-model")
|
||||
config_path = tmp_path / "config.yaml"
|
||||
config_path.write_text("{}", encoding="utf-8")
|
||||
cache_path = tmp_path / "models_cache.profile.json"
|
||||
cache_path.write_text("{}", encoding="utf-8")
|
||||
old = time.time() - 600.0
|
||||
os.utime(cache_path, (old, old))
|
||||
fingerprint = {"profile": "demo"}
|
||||
rebuild_count = 0
|
||||
timeout_waits = []
|
||||
original_wait_for = threading.Condition.wait_for
|
||||
|
||||
monkeypatch.setattr(cfg, "_LIVE_REBUILD_BUDGET_SECONDS", 0.0, raising=False)
|
||||
monkeypatch.setattr(cfg, "_get_config_path", lambda: config_path)
|
||||
monkeypatch.setattr(cfg, "_cfg_path", config_path, raising=False)
|
||||
monkeypatch.setattr(cfg, "_cfg_mtime", config_path.stat().st_mtime, raising=False)
|
||||
monkeypatch.setattr(cfg, "_get_models_cache_path", lambda: cache_path)
|
||||
monkeypatch.setattr(cfg, "_load_models_cache_from_disk", lambda: None)
|
||||
monkeypatch.setattr(cfg, "_load_stale_models_cache_from_disk", lambda: stale_catalog)
|
||||
monkeypatch.setattr(cfg, "_models_cache_source_fingerprint", lambda: fingerprint)
|
||||
monkeypatch.setattr(cfg, "_save_models_cache_to_disk", lambda _cache: None)
|
||||
|
||||
def _wait_for(self, predicate, timeout=None):
|
||||
if self is not cfg._cache_build_cv:
|
||||
return original_wait_for(self, predicate, timeout)
|
||||
timeout_waits.append(timeout)
|
||||
if timeout is None:
|
||||
cfg._cache_build_in_progress = False
|
||||
return True
|
||||
return original_wait_for(self, predicate, timeout=timeout)
|
||||
|
||||
def _invoke_models_rebuild(_builder):
|
||||
nonlocal rebuild_count
|
||||
rebuild_count += 1
|
||||
return rebuilt_catalog
|
||||
|
||||
monkeypatch.setattr(cfg, "_cache_build_in_progress", True, raising=False)
|
||||
monkeypatch.setattr(threading.Condition, "wait_for", _wait_for)
|
||||
monkeypatch.setattr(cfg, "_invoke_models_rebuild", _invoke_models_rebuild)
|
||||
|
||||
assert cfg.get_available_models(force_refresh=True) == rebuilt_catalog
|
||||
assert rebuild_count == 1
|
||||
assert None in timeout_waits
|
||||
assert cfg._available_models_cache == rebuilt_catalog
|
||||
assert cfg._cache_build_in_progress is False
|
||||
|
||||
|
||||
def test_session_visit_overlapping_stale_calls_do_not_duplicate_over_budget_rebuild(tmp_path, monkeypatch):
|
||||
import api.config as cfg
|
||||
|
||||
Reference in new issue
Block a user