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

Shorten some timeouts in `subint_forkserver` suites

subint_forkserver_backend
Gud Boi 2026-04-23 11:01:56 -04:00
parent a72deef709
commit f5f37b69e6
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/spawn/test_subint_forkserver.py
View File

@ -43,6 +43,7 @@ Gating
from __future__ import annotations from __future__ import annotations
from functools import partial from functools import partial
import os import os
from pathlib import Path
import platform import platform
import select import select
import signal import signal
@ -179,7 +180,8 @@ async def run_fork_in_non_trio_thread(
# inner `trio.fail_after()` so assertion failures fire fast # inner `trio.fail_after()` so assertion failures fire fast
# under normal conditions. # under normal conditions.
@pytest.mark.timeout(30, method='thread') @pytest.mark.timeout(30, method='thread')
def test_fork_from_worker_thread_via_trio() -> None: def test_fork_from_worker_thread_via_trio(
) -> None:
''' '''
Baseline: inside `trio.run()`, call Baseline: inside `trio.run()`, call
`fork_from_worker_thread()` via `trio.to_thread.run_sync()`, `fork_from_worker_thread()` via `trio.to_thread.run_sync()`,
@ -460,10 +462,13 @@ def _process_alive(pid: int) -> bool:
'Flip this mark (or drop it) once the gap is closed.' 'Flip this mark (or drop it) once the gap is closed.'
), ),
) )
@pytest.mark.timeout(60, method='thread') @pytest.mark.timeout(
30,
method='thread',
)
def test_orphaned_subactor_sigint_cleanup_DRAFT( def test_orphaned_subactor_sigint_cleanup_DRAFT(
reg_addr: tuple[str, int | str], reg_addr: tuple[str, int | str],
tmp_path, tmp_path: Path,
) -> None: ) -> None:
''' '''
DRAFT — orphaned-subactor SIGINT survivability under the DRAFT — orphaned-subactor SIGINT survivability under the
@ -564,7 +569,8 @@ def test_orphaned_subactor_sigint_cleanup_DRAFT(
# step 4+5: SIGINT the orphan, poll for exit. # step 4+5: SIGINT the orphan, poll for exit.
os.kill(child_pid, signal.SIGINT) os.kill(child_pid, signal.SIGINT)
cleanup_deadline: float = time.monotonic() + 10.0 timeout: float = 6.0
cleanup_deadline: float = time.monotonic() + timeout
while time.monotonic() < cleanup_deadline: while time.monotonic() < cleanup_deadline:
if not _process_alive(child_pid): if not _process_alive(child_pid):
return # <- success path return # <- success path