jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Hipshot, try to avoid subs teardown race

fix_kbi_in_ctx_block
Tyler Goodlet 2021-10-05 12:18:26 -04:00
parent 8fd515c7b9
commit 4f831abe25
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/test_task_broadcasting.py
View File

@ -1,5 +1,6 @@
""" """
Broadcast channels for fan-out to local tasks. Broadcast channels for fan-out to local tasks.
""" """
from contextlib import asynccontextmanager from contextlib import asynccontextmanager
from functools import partial from functools import partial
@ -332,6 +333,9 @@ def test_ensure_slow_consumers_lag_out(
await trio.sleep(delay) await trio.sleep(delay)
if task.name == 'sub_1': if task.name == 'sub_1':
# trigger checkpoint to clean out other subs
await trio.sleep(0)
# the non-lagger got # the non-lagger got
# a ``trio.EndOfChannel`` # a ``trio.EndOfChannel``
# because the ``tx`` below was closed # because the ``tx`` below was closed