odd interation between pytest fixture loop and flake

Author: max-sixty

xarray/tests/test_backends_file_manager.py

@@ -1,4 +1,3 @@
-import collections
 import gc
 import pickle
 import threading

xarray/tests/test_distributed.py

@@ -10,6 +10,7 @@
 
 from dask.distributed import Client, Lock
 from distributed.utils_test import cluster, gen_cluster
+from distributed.utils_test import loop  # noqa
 from distributed.client import futures_of
 
 import xarray as xr
@@ -57,7 +58,7 @@ def tmp_netcdf_filename(tmpdir):
 ]
 
 
-@pytest.mark.parametrize('engine,nc_format', ENGINES_AND_FORMATS)
+@pytest.mark.parametrize('engine,nc_format', ENGINES_AND_FORMATS)  # noqa
 def test_dask_distributed_netcdf_roundtrip(
         loop, tmp_netcdf_filename, engine, nc_format):
 
@@ -87,7 +88,7 @@ def test_dask_distributed_netcdf_roundtrip(
                 assert_allclose(original, computed)
 
 
-@pytest.mark.parametrize('engine,nc_format', ENGINES_AND_FORMATS)
+@pytest.mark.parametrize('engine,nc_format', ENGINES_AND_FORMATS)  # noqa
 def test_dask_distributed_read_netcdf_integration_test(
         loop, tmp_netcdf_filename, engine, nc_format):
 
@@ -111,7 +112,7 @@ def test_dask_distributed_read_netcdf_integration_test(
                 assert_allclose(original, computed)
 
 
-@requires_zarr
+@requires_zarr  # noqar
 @pytest.mark.parametrize('consolidated', [True, False])
 @pytest.mark.parametrize('compute', [True, False])
 def test_dask_distributed_zarr_integration_test(loop, consolidated, compute):
@@ -137,7 +138,7 @@ def test_dask_distributed_zarr_integration_test(loop, consolidated, compute):
                     assert_allclose(original, computed)
 
 
-@requires_rasterio
+@requires_rasterio  # noqa
 def test_dask_distributed_rasterio_integration_test(loop):
     with create_tmp_geotiff() as (tmp_file, expected):
         with cluster() as (s, [a, b]):
@@ -148,7 +149,7 @@ def test_dask_distributed_rasterio_integration_test(loop):
                 assert_allclose(actual, expected)
 
 
-@requires_cfgrib
+@requires_cfgrib  # noqa
 def test_dask_distributed_cfgrib_integration_test(loop):
     with cluster() as (s, [a, b]):
         with Client(s['address'], loop=loop):