From f73f875a54ec87652ee6d67ced831a78e971a03c Mon Sep 17 00:00:00 2001 From: Artur Shiriev Date: Sun, 4 Oct 2026 12:28:02 +0300 Subject: [PATCH] Make concurrent integration test assertions order-independent --- tests/test_integration.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/test_integration.py b/tests/test_integration.py index 2ea1622..24c9585 100644 --- a/tests/test_integration.py +++ b/tests/test_integration.py @@ -522,7 +522,7 @@ async def handler(msg: dict[str, int]) -> None: # Every later message still reached the handler: the application kept consuming after # the signal that used to kill it. This is the regression, not merely "the loop is alive". assert seen == n_messages - assert [m["id"] for m in processed] == [1, 2] + assert sorted(m["id"] for m in processed) == [1, 2] async def test_real_kafka_direct_ack_from_handler_is_refused(kafka_bootstrap_servers: str) -> None: @@ -565,7 +565,7 @@ async def handler(msg: dict[str, int], message: KafkaMessage) -> None: # Message 0 was refused and never completed; 1 and 2 processed normally. assert len(errors) == 1 assert "Do not call `message.ack()`" in errors[0] - assert [m["id"] for m in processed] == [1, 2] + assert sorted(m["id"] for m in processed) == [1, 2] async def _committed_offsets(bootstrap_servers: str, group_id: str) -> dict[int, int]: