mirror of
https://github.com/BerriAI/litellm.git
synced 2026-11-10 08:28:25 +00:00
test: align startup fixtures with owned database lifespan
This commit is contained in:
parent
b50f283c04
commit
d85205b41b
2 changed files with 11 additions and 4 deletions
|
|
@ -113,7 +113,7 @@ async def test_admin_mcp_failure_still_closes_proxy_resources(
|
|||
message: Final = "LITELLM_LICENSE" if failure_phase == "license" else f"{failure_phase} failed"
|
||||
async def run_lifespan() -> None:
|
||||
async with admin_mcp_proxy.router.lifespan_context(admin_mcp_proxy) as state:
|
||||
assert state == {"tracing_receiver": None}
|
||||
assert state == {"tracing_receiver": None, "database": None}
|
||||
if failure_phase == "serving":
|
||||
raise RuntimeError("serving failed")
|
||||
if failure_phase == "cancelled":
|
||||
|
|
@ -162,7 +162,7 @@ async def test_proxy_shutdown_drains_active_admin_tool_before_closing_connector(
|
|||
transport=httpx2.ASGITransport(app=admin_mcp_proxy), base_url="http://localhost:4000"
|
||||
) as client:
|
||||
async with admin_mcp_proxy.router.lifespan_context(admin_mcp_proxy) as state:
|
||||
assert state == {"tracing_receiver": None}
|
||||
assert state == {"tracing_receiver": None, "database": None}
|
||||
request: Final = asyncio.create_task(client.post(
|
||||
"/admin/mcp",
|
||||
headers={"Authorization": "Bearer admin", "Accept": "application/json, text/event-stream"},
|
||||
|
|
|
|||
|
|
@ -1838,6 +1838,12 @@ async def test_proxy_startup_says_a_lingering_migrate_from_variable_can_be_delet
|
|||
|
||||
|
||||
class _PrismaClientWhoseDatabaseRejectsQueries:
|
||||
def __init__(self) -> None:
|
||||
self.disconnect_calls = 0
|
||||
|
||||
async def disconnect(self) -> None:
|
||||
self.disconnect_calls += 1
|
||||
|
||||
class _Database:
|
||||
async def query_raw(self, query, *args):
|
||||
raise RuntimeError("permission denied for table LiteLLM_CredentialsTable")
|
||||
|
|
@ -1852,7 +1858,8 @@ async def test_proxy_startup_stops_when_the_requested_migration_fails(monkeypatc
|
|||
from litellm.proxy.proxy_server import proxy_startup_event
|
||||
|
||||
_boot_with_general_settings(monkeypatch, tmp_path, {"master_key": "sk-a-safe-master-key"})
|
||||
monkeypatch.setattr("litellm.proxy.proxy_server.prisma_client", _PrismaClientWhoseDatabaseRejectsQueries())
|
||||
prisma: Final = _PrismaClientWhoseDatabaseRejectsQueries()
|
||||
monkeypatch.setattr("litellm.proxy.proxy_server.prisma_client", prisma)
|
||||
monkeypatch.setenv("LITELLM_MIGRATE_FROM_MASTER_KEY", PUBLICLY_KNOWN_KEY)
|
||||
|
||||
with (
|
||||
|
|
@ -1865,6 +1872,7 @@ async def test_proxy_startup_stops_when_the_requested_migration_fails(monkeypatc
|
|||
notices = [record.getMessage() for record in caplog.records if "LITELLM_MIGRATE_FROM_MASTER_KEY" in record.message]
|
||||
assert len(notices) == 1
|
||||
assert "Could not migrate stored values" in notices[0]
|
||||
assert prisma.disconnect_calls == 1
|
||||
|
||||
|
||||
@pytest.mark.asyncio
|
||||
|
|
@ -15587,4 +15595,3 @@ async def test_spend_capture_rate_check_job_clears_the_gauge_once_the_setting_is
|
|||
call(api_provider="openai", capture_rate=0.97),
|
||||
call(api_provider="openai", capture_rate=None),
|
||||
]
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue