From 012a60c14bb46ee6f21d3c2795fd7352426fb88e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Alex=20Gr=C3=B6nholm?= Date: Sun, 13 Oct 2024 01:20:13 +0300 Subject: [PATCH] Made test_start_task_soon_cancel_immediately() less flaky --- tests/test_from_thread.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/test_from_thread.py b/tests/test_from_thread.py index c37614e7..e4c29ce0 100644 --- a/tests/test_from_thread.py +++ b/tests/test_from_thread.py @@ -419,6 +419,7 @@ def test_start_task_soon_cancel_immediately( self, anyio_backend_name: str, anyio_backend_options: dict[str, Any] ) -> None: cancelled = False + done_event = threading.Event() async def event_waiter() -> None: nonlocal cancelled @@ -426,10 +427,13 @@ async def event_waiter() -> None: await sleep(3) except get_cancelled_exc_class(): cancelled = True + finally: + done_event.set() with start_blocking_portal(anyio_backend_name, anyio_backend_options) as portal: future = portal.start_task_soon(event_waiter) future.cancel() + done_event.wait(10) assert cancelled