From 1b0048a5c6c322261f992b5d6b3a735418cc303e Mon Sep 17 00:00:00 2001 From: yucheng Date: Wed, 23 Sep 2026 11:08:24 +0000 Subject: [PATCH] test(integration): wait for worker count to recover after SIGKILL Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> --- .../observability/test_guardrail_effects.py | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/tests/integration/observability/test_guardrail_effects.py b/tests/integration/observability/test_guardrail_effects.py index 27d0362b316..67b98506418 100644 --- a/tests/integration/observability/test_guardrail_effects.py +++ b/tests/integration/observability/test_guardrail_effects.py @@ -970,7 +970,16 @@ def test_responses_pre_call_denial_stream_survives_worker_kill(gateway: Gateway, ) assert len(children) >= 2, children os.kill(children[0], signal.SIGKILL) - eventually(lambda: group_members(owned.process.pid), lambda members: all(m.is_running() for m in members)) + expected: Final = len(children) + eventually( + lambda: tuple( + member.pid + for member in group_members(owned.process.pid) + if member.pid != owned.process.pid and member.is_running() + ), + lambda pids: len(pids) >= expected, + seconds=30, + ) def burst(index: int) -> httpx.Response: return candidate.request(