Skip to content

Commit fdc5a1a

Browse files
committed
tweaks
1 parent 3644a10 commit fdc5a1a

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

distributed/tests/test_scheduler.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -766,6 +766,7 @@ async def test_update_graph_culls(s, a, b):
766766
def test_io_loop(loop):
767767
s = Scheduler(loop=loop, port=0, dashboard_address=":0", validate=True)
768768
assert s.io_loop is loop
769+
s.close()
769770

770771

771772
@gen_cluster(client=True)

distributed/tests/test_worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1514,7 +1514,7 @@ async def test_interface_async(cleanup, loop, Worker):
15141514
@pytest.mark.asyncio
15151515
@pytest.mark.parametrize("Worker", [Worker, Nanny])
15161516
async def test_protocol_from_scheduler_address(cleanup, Worker):
1517-
ucp = pytest.importorskip("ucp")
1517+
pytest.importorskip("ucp")
15181518

15191519
async with Scheduler(protocol="ucx", port=0, dashboard_address=":0") as s:
15201520
assert s.address.startswith("ucx://")

0 commit comments

Comments
 (0)