goodboy
/
tractor
1
0
Fork 1
Code Issues 1 Pull Requests 4 Packages Projects Releases Wiki Activity

Pass explicit kwargs to new discovery test funcs

dereg_on_channel_aclose
Tyler Goodlet 2020-08-13 13:26:08 -04:00
parent ec5d443ee5
commit 451170bb63
1 changed files with 26 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
tests/test_discovery.py
View File

@ -196,11 +196,13 @@ def test_subactors_unregister_on_cancel(
""" """
with pytest.raises(KeyboardInterrupt): with pytest.raises(KeyboardInterrupt):
tractor.run( tractor.run(
spawn_and_check_registry, partial(
arb_addr, spawn_and_check_registry,
use_signal, arb_addr,
False, # remote arbiter use_signal,
with_streaming, remote_arbiter=False,
with_streaming=with_streaming,
),
arbiter_addr=arb_addr arbiter_addr=arb_addr
) )
@ -220,11 +222,13 @@ def test_subactors_unregister_on_cancel_remote_daemon(
""" """
with pytest.raises(KeyboardInterrupt): with pytest.raises(KeyboardInterrupt):
tractor.run( tractor.run(
spawn_and_check_registry, partial(
arb_addr, spawn_and_check_registry,
use_signal, arb_addr,
True, # remote arbiter use_signal,
with_streaming, remote_arbiter=True,
with_streaming=with_streaming,
),
# XXX: required to use remote daemon! # XXX: required to use remote daemon!
arbiter_addr=arb_addr arbiter_addr=arb_addr
) )
@ -300,10 +304,12 @@ def test_close_channel_explicit(
""" """
with pytest.raises(KeyboardInterrupt): with pytest.raises(KeyboardInterrupt):
tractor.run( tractor.run(
close_chans_before_nursery, partial(
arb_addr, close_chans_before_nursery,
use_signal, arb_addr,
False, use_signal,
remote_arbiter=False,
),
# XXX: required to use remote daemon! # XXX: required to use remote daemon!
arbiter_addr=arb_addr arbiter_addr=arb_addr
) )
@ -322,10 +328,12 @@ def test_close_channel_explicit_remote_arbiter(
""" """
with pytest.raises(KeyboardInterrupt): with pytest.raises(KeyboardInterrupt):
tractor.run( tractor.run(
close_chans_before_nursery, partial(
arb_addr, close_chans_before_nursery,
use_signal, arb_addr,
True, use_signal,
remote_arbiter=True,
),
# XXX: required to use remote daemon! # XXX: required to use remote daemon!
arbiter_addr=arb_addr arbiter_addr=arb_addr
) )