21
21
22
22
from dask .distributed import Client , Lock
23
23
from distributed .client import futures_of
24
- from distributed .utils_test import ( # noqa: F401
25
- cleanup ,
26
- client ,
24
+ from distributed .utils_test import (
25
+ cleanup , # noqa: F401
26
+ client , # noqa: F401
27
27
cluster ,
28
- cluster_fixture ,
28
+ cluster_fixture , # noqa: F401
29
29
gen_cluster ,
30
- loop ,
31
- loop_in_thread ,
30
+ loop , # noqa: F401
31
+ loop_in_thread , # noqa: F401
32
32
)
33
33
34
34
import xarray as xr
49
49
)
50
50
from xarray .tests .test_dataset import create_test_data
51
51
52
- loop = loop # loop is an imported fixture, which flake8 has issues ack-ing
53
- client = client # client is an imported fixture, which flake8 has issues ack-ing
54
-
55
52
56
53
@pytest .fixture
57
54
def tmp_netcdf_filename (tmpdir ):
@@ -89,7 +86,10 @@ def tmp_netcdf_filename(tmpdir):
89
86
90
87
@pytest .mark .parametrize ("engine,nc_format" , ENGINES_AND_FORMATS )
91
88
def test_dask_distributed_netcdf_roundtrip (
92
- loop , tmp_netcdf_filename , engine , nc_format
89
+ loop , # noqa: F811
90
+ tmp_netcdf_filename ,
91
+ engine ,
92
+ nc_format ,
93
93
):
94
94
if engine not in ENGINES :
95
95
pytest .skip ("engine not available" )
@@ -119,7 +119,8 @@ def test_dask_distributed_netcdf_roundtrip(
119
119
120
120
@requires_netCDF4
121
121
def test_dask_distributed_write_netcdf_with_dimensionless_variables (
122
- loop , tmp_netcdf_filename
122
+ loop , # noqa: F811
123
+ tmp_netcdf_filename ,
123
124
):
124
125
with cluster () as (s , [a , b ]):
125
126
with Client (s ["address" ], loop = loop ):
@@ -199,7 +200,10 @@ def test_open_mfdataset_multiple_files_parallel(parallel, tmp_path):
199
200
200
201
@pytest .mark .parametrize ("engine,nc_format" , ENGINES_AND_FORMATS )
201
202
def test_dask_distributed_read_netcdf_integration_test (
202
- loop , tmp_netcdf_filename , engine , nc_format
203
+ loop , # noqa: F811
204
+ tmp_netcdf_filename ,
205
+ engine ,
206
+ nc_format ,
203
207
):
204
208
if engine not in ENGINES :
205
209
pytest .skip ("engine not available" )
@@ -223,7 +227,7 @@ def test_dask_distributed_read_netcdf_integration_test(
223
227
# heads-up, this is using quite private zarr API
224
228
# https://github.com/dask/dask/blob/e04734b4d8959ba259801f2e2a490cb4ee8d891f/dask/tests/test_distributed.py#L338-L358
225
229
@pytest .fixture
226
- def zarr (client ):
230
+ def zarr (client ): # noqa: F811
227
231
zarr_lib = pytest .importorskip ("zarr" )
228
232
# Zarr-Python 3 lazily allocates a dedicated thread/IO loop
229
233
# for to execute async tasks. To avoid having this thread
@@ -248,7 +252,7 @@ def zarr(client):
248
252
@pytest .mark .parametrize ("consolidated" , [True , False ])
249
253
@pytest .mark .parametrize ("compute" , [True , False ])
250
254
def test_dask_distributed_zarr_integration_test (
251
- client ,
255
+ client , # noqa: F811
252
256
zarr ,
253
257
consolidated : bool ,
254
258
compute : bool ,
0 commit comments