From 4cc5a8cc635bc318544f0a843ab5c03d9e2a72de Mon Sep 17 00:00:00 2001 From: yucheng Date: Sat, 26 Sep 2026 01:27:11 +0000 Subject: [PATCH] test(integration): release the upstream gate if the disconnect burst itself fails Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> --- .../test_passthrough_upstream_error_chaos.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/integration/observability/test_passthrough_upstream_error_chaos.py b/tests/integration/observability/test_passthrough_upstream_error_chaos.py index a42eb576699..eb0bca30d8a 100644 --- a/tests/integration/observability/test_passthrough_upstream_error_chaos.py +++ b/tests/integration/observability/test_passthrough_upstream_error_chaos.py @@ -178,11 +178,11 @@ async def test_passthrough_disconnect_burst_logs_every_failure_once(gateway: Gat path.write_text(yaml.safe_dump(config)) with owned_proxy_process(gateway, tmp_path, {}, config=path, workers=2) as owned: candidate: Final = owned.gateway - call_ids: Final = await asyncio.gather( - *(_first_frame_then_close(str(candidate.client.base_url), candidate.key) for _ in range(20)) - ) - assert len(set(call_ids)) == 20, call_ids try: + call_ids: Final = await asyncio.gather( + *(_first_frame_then_close(str(candidate.client.base_url), candidate.key) for _ in range(20)) + ) + assert len(set(call_ids)) == 20, call_ids for call_id in call_ids: _single_spend_row(call_id) error_information: Final = _error_information(call_id)