goodboy
/
tractor
1
0
Fork 2
Code Issues 5 Pull Requests 6 Packages Projects Releases Wiki Activity

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
subint_forkserver_backend
Gud Boi 2026-05-13 15:47:36 -04:00
parent 7d0a53d205
commit b10011a36e
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/test_clustering.py
View File

@ -77,6 +77,7 @@ async def worker(
@tractor_test @tractor_test
async def test_streaming_to_actor_cluster( async def test_streaming_to_actor_cluster(
tpt_proto: str, tpt_proto: str,
is_forking_spawner: bool,
): ):
''' '''
Open an actor "cluster" using the (experimental) `._clustering` 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' 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 ( async with (
open_actor_cluster(modules=[__name__]) as portals, open_actor_cluster(modules=[__name__]) as portals,