scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-11-14 09:03:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 214

fix(alerts): preserve incidents with simultaneous observations

Browse source
This commit is contained in:
moe-berri 2026-11-07 11:55:04 +08:00
parent 33226cc05f
commit be953d8abc
2 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
litellm/repositories/issues.py
View file

@ -487,7 +487,7 @@ class IssuesRepository:
"""WITH changed AS (
UPDATE "LiteLLM_Issue" SET active=false,
status=CASE WHEN status='open' THEN 'resolved' ELSE status END,updated_at=CURRENT_TIMESTAMP
WHERE id=ANY($1::text[]) AND kind='performance' AND active AND last_seen<=$2::timestamp(3)
WHERE id=ANY($1::text[]) AND kind='performance' AND active AND last_seen<$2::timestamp(3)
RETURNING id
) SELECT count(*)::int AS count FROM changed""",
list(ids),

10
tests/integration/database/test_issues.py
View file

@ -1067,7 +1067,15 @@ async def test_provider_recovery_pages_saved_cohorts_and_rejects_stale_observati
assert first[0].id == inputs[0].id and second[0].id == inputs[1].id
assert await store.set_status(inputs[0].id, "dismissed", "open") is not None
assert await store.recover_issue_ids((inputs[0].id,), template.observed_at - timedelta(seconds=1)) == 0
assert await store.recover_issue_ids((inputs[0].id, inputs[1].id), template.observed_at) == 2
assert await store.recover_issue_ids((inputs[0].id, inputs[1].id), template.observed_at) == 0, (
"A recovery at the last observed timestamp must not close the alert"
)
assert (
await store.recover_issue_ids(
(inputs[0].id, inputs[1].id), template.observed_at + timedelta(milliseconds=1)
)
== 2
)
dismissed: Final = await store.get_issue(inputs[0].id)
resolved: Final = await store.get_issue(inputs[1].id)
assert dismissed is not None and not dismissed.active and dismissed.status == "dismissed"