stackchain/stackchain-dashboard
1
0
Fork 0
Code Issues 9 Pull Requests 1 Actions Packages Projects Releases 713 Wiki Activity

test: make health timing gate deterministic (Closes #1289)
All checks were successful
CI / lint (pull_request) Successful in 4m10s
Details
CI / build-release (pull_request) Successful in 8s
Details
CI / release-candidate (pull_request) Has been skipped
Details
CI / browser-journey (pull_request) Successful in 7m24s
Details

Browse Source
This commit is contained in:
timmy 2026-08-23 02:40:35 +00:00
parent 73017c1a30
commit fe1049ee99
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/test_authored_idempotency.py
View File

@ -419,11 +419,12 @@ async def test_slow_ledger_completion_does_not_block_health_requests(monkeypatch
return {"id": 249, "body": body} return {"id": 249, "body": body}
started = threading.Event() started = threading.Event()
release = threading.Event()
original_complete = main._idempotency_ledger.complete original_complete = main._idempotency_ledger.complete
def slow_complete(key, response): def slow_complete(key, response):
started.set() started.set()
time.sleep(0.2) assert release.wait(1)
return original_complete(key, response) return original_complete(key, response)
monkeypatch.setattr(main._idempotency_ledger, "complete", slow_complete) monkeypatch.setattr(main._idempotency_ledger, "complete", slow_complete)
@ -432,15 +433,16 @@ async def test_slow_ledger_completion_does_not_block_health_requests(monkeypatch
transport = httpx.ASGITransport(app=main.app) transport = httpx.ASGITransport(app=main.app)
async with httpx.AsyncClient(transport=transport, base_url="http://test") as client: async with httpx.AsyncClient(transport=transport, base_url="http://test") as client:
started_at = asyncio.get_running_loop().time()
authored = asyncio.create_task(client.post( authored = asyncio.create_task(client.post(
"/api/v1/repos/stackchain/api/issues/248/comments", "/api/v1/repos/stackchain/api/issues/248/comments",
json={"body": "Persist without freezing"}, json={"body": "Persist without freezing"},
headers={"Idempotency-Key": "slow-completion-248"}, headers={"Idempotency-Key": "slow-completion-248"},
)) ))
assert await asyncio.to_thread(started.wait, 1) assert await asyncio.to_thread(started.wait, 1)
started_at = asyncio.get_running_loop().time()
health = await client.get("/healthz") health = await client.get("/healthz")
health_elapsed = asyncio.get_running_loop().time() - started_at health_elapsed = asyncio.get_running_loop().time() - started_at
release.set()
authored_response = await authored authored_response = await authored
assert health.status_code == 200 assert health.status_code == 200