45fd01a15e
Владелец возразил на моё утверждение, что gemini-3.7-flash не существует.
Он прав, утверждение было неверным, и я повторил его в четырёх заданиях.
gemini-3.7-flash — настоящее семейство, уровень усилия у неё отдельный
параметр. В интерфейсе Antigravity это видно прямо: пункт «Gemini 3.7
Flash» с вложенным выбором Low/Medium/High. В коде это отражено:
_display_to_cli разбирает «Gemini 3.7 Flash (High)» в пару
("gemini-3.7-flash", "high"). Меня ввела в заблуждение первая колонка
вывода agy models со склеенными идентификаторами.
Настоящий дефект был в коде: _model_supported_efforts вызывала
discover_models() БЕЗ профиля, то есть в глобальном окружении без входа.
Карта поддерживаемых усилий оставалась пустой, подстановка уровня по
умолчанию не срабатывала, и agy отвергал вызов с «requires --effort» —
при совершенно настоящей модели.
profile_id проведён через agy_generate в _model_supported_efforts.
Проверено исполнением: gemini-3.7-flash без указания усилия отрабатывает
и возвращает ответ.
Моки в test_antigravity_concurrency приведены к терпимости по kwargs.
Добавлена поправка agents/inbox/2026-08-24-CORRECTION-gemini-model-names.md:
ложное утверждение попало в A9, A11, A18 и B8, и без опровержения кто-то
чинил бы несуществующую проблему или сломал рабочую конфигурацию.
Тесты: 359 passed, ruff чисто.
Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
79 lines
3.4 KiB
Python
79 lines
3.4 KiB
Python
"""Concurrency & Race Condition Regression Tests for Antigravity Adapter Credential Swapping.
|
|
|
|
Verifies:
|
|
1. Concurrent invocations with different profiles do not clobber shared gemini:antigravity credentials.
|
|
2. Original Windows Credential Manager state is restored cleanly upon completion.
|
|
3. Timeout or exception in subprocess does not leave credentials corrupted or swapped.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import concurrent.futures
|
|
import time
|
|
from unittest.mock import MagicMock, patch
|
|
import pytest
|
|
|
|
from antigravity_provider.router.adapters.antigravity_adapter import AntigravityAdapter
|
|
from antigravity_provider.router.profile_manager import ProfileAuthManager
|
|
from antigravity_provider.router.router_config import RouterProfileConfig
|
|
|
|
|
|
def test_concurrent_antigravity_credential_isolation(tmp_path, monkeypatch):
|
|
"""Verify concurrent invocations for distinct profiles maintain environment isolation."""
|
|
monkeypatch.setenv("HERMES_HOME", str(tmp_path / "hermes"))
|
|
|
|
adapter = AntigravityAdapter()
|
|
observed_envs_during_run = []
|
|
|
|
def mock_load_profile_auth(prov, profile_id):
|
|
return {"token": f"token_for_{profile_id}"}
|
|
|
|
def mock_agy_generate(req, custom_env=None, **kwargs):
|
|
user_prof = custom_env.get("USERPROFILE") if custom_env else None
|
|
observed_envs_during_run.append((req.get("profile_id"), user_prof))
|
|
time.sleep(0.05)
|
|
return {"content": "ok"}
|
|
|
|
with patch.object(ProfileAuthManager, "load_profile_auth", side_effect=mock_load_profile_auth), \
|
|
patch("antigravity_provider.router.adapters.antigravity_adapter.agy_generate", side_effect=mock_agy_generate):
|
|
|
|
p1 = RouterProfileConfig(profile_id="ag-prof-1", provider="antigravity")
|
|
p2 = RouterProfileConfig(profile_id="ag-prof-2", provider="antigravity")
|
|
p3 = RouterProfileConfig(profile_id="ag-prof-3", provider="antigravity")
|
|
|
|
def run_invoke(p):
|
|
return adapter.invoke(p, {"profile_id": p.profile_id, "messages": []})
|
|
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
|
|
futs = [executor.submit(run_invoke, p) for p in (p1, p2, p3)]
|
|
results = [f.result() for f in futs]
|
|
|
|
assert len(results) == 3
|
|
for r in results:
|
|
assert r == {"content": "ok"}
|
|
|
|
# Each profile must have run with its own isolated environment path
|
|
for pid, env_prof in observed_envs_during_run:
|
|
assert pid in env_prof, f"Profile {pid} did not run with isolated env: {env_prof}"
|
|
|
|
|
|
def test_credential_restoration_on_subprocess_exception(tmp_path, monkeypatch):
|
|
"""Verify custom_env isolation handles exceptions cleanly."""
|
|
monkeypatch.setenv("HERMES_HOME", str(tmp_path / "hermes"))
|
|
|
|
adapter = AntigravityAdapter()
|
|
|
|
def mock_load_profile_auth(prov, profile_id):
|
|
return {"token": "valid_token"}
|
|
|
|
def mock_agy_generate_fail(req, custom_env=None, **kwargs):
|
|
raise RuntimeError("CLI process crashed")
|
|
|
|
with patch.object(ProfileAuthManager, "load_profile_auth", side_effect=mock_load_profile_auth), \
|
|
patch("antigravity_provider.router.adapters.antigravity_adapter.agy_generate", side_effect=mock_agy_generate_fail):
|
|
|
|
p = RouterProfileConfig(profile_id="ag-prof-err", provider="antigravity")
|
|
with pytest.raises(RuntimeError, match="CLI process crashed"):
|
|
adapter.invoke(p, {"messages": []})
|
|
|
|
# Must be cleanly restored
|
|
assert True
|