From b10011a36eeaef3f8a14e92748ee191893bf3536 Mon Sep 17 00:00:00 2001 From: goodboy Date: Wed, 13 May 2026 15:47:36 -0400 Subject: [PATCH] Adjust `test_streaming_to_actor_cluster` timeout For forking spawner backends that is. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code --- tests/test_clustering.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/tests/test_clustering.py b/tests/test_clustering.py index cb4e2568..efb47d19 100644 --- a/tests/test_clustering.py +++ b/tests/test_clustering.py @@ -77,6 +77,7 @@ async def worker( @tractor_test async def test_streaming_to_actor_cluster( tpt_proto: str, + is_forking_spawner: bool, ): ''' Open an actor "cluster" using the (experimental) `._clustering` @@ -88,7 +89,11 @@ async def test_streaming_to_actor_cluster( f'Test currently fails with tpt-proto={tpt_proto!r}\n' ) - with trio.fail_after(6): + delay: float = ( + 10 if is_forking_spawner + else 6 + ) + with trio.fail_after(delay): async with ( open_actor_cluster(modules=[__name__]) as portals,