Skip to content

Commit 328c131

Browse files
committed
add async test for scheduler start time
1 parent 3115900 commit 328c131

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

distributed/benchmarks/scheduler.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@
33
import random
44

55
from dask import compute, delayed
6-
from distributed import Client, wait
6+
from distributed import Client, wait, Scheduler
7+
from distributed.tests import gen_test
78

89

910
class SchedulerComputeDepsInMemory(object):
@@ -35,3 +36,9 @@ def time_compute_deps_already_in_memory(self):
3536
xref https://github.com/dask/distributed/pull/3293
3637
"""
3738
compute(*self.x, scheduler=self.client)
39+
40+
41+
@gen_test()
42+
async def test_start_scheduler():
43+
async with Scheduler(port=0):
44+
pass

0 commit comments

Comments
 (0)