▾ distributed

Module test_stress

distributed.tests.test_stress

Functions

▷ def test_cancel_stress_sync(loop)
source link
▷ def test_stress_gc(loop, func, n) @pytest.mark.parametrize(("func", "n"), [(slowinc, 100), (inc, 1000)])
@pytest.mark.parametrize(("func", "n"), [(slowinc, 100), (inc, 1000)])
def test_stress_gc(
loop,
func,
n,
)
source link
▷ def vsum(*args)
source link