@@ -1366,21 +1366,19 @@ async def test_register_worker_callbacks_err(c, s, a, b):
13661366
13671367
13681368@gen_cluster (nthreads = [])
1369- async def test_local_directory (s ):
1370- with tmpfile () as fn :
1371- with dask .config .set (temporary_directory = fn ):
1372- w = await Worker (s .address )
1373- assert w .local_directory .startswith (fn )
1374- assert "dask-worker-space" in w .local_directory
1369+ async def test_local_directory (s , tmp_path ):
1370+ with dask .config .set (temporary_directory = str (tmp_path )):
1371+ w = await Worker (s .address )
1372+ assert w .local_directory .startswith (str (tmp_path ))
1373+ assert "dask-worker-space" in w .local_directory
13751374
13761375
13771376@gen_cluster (nthreads = [])
1378- async def test_local_directory_make_new_directory (s ):
1379- with tmpfile () as fn :
1380- w = await Worker (s .address , local_directory = os .path .join (fn , "foo" , "bar" ))
1381- assert w .local_directory .startswith (fn )
1382- assert "foo" in w .local_directory
1383- assert "dask-worker-space" in w .local_directory
1377+ async def test_local_directory_make_new_directory (s , tmp_path ):
1378+ w = await Worker (s .address , local_directory = str (tmp_path / "foo" / "bar" ))
1379+ assert w .local_directory .startswith (str (tmp_path ))
1380+ assert "foo" in w .local_directory
1381+ assert "dask-worker-space" in w .local_directory
13841382
13851383
13861384@pytest .mark .skipif (not LINUX , reason = "Need 127.0.0.2 to mean localhost" )
0 commit comments