xfail zarr test on Windows

xarray/tests/test_backends.py

@@ -2945,6 +2945,10 @@
 
 
 @requires_zarr
+@pytest.mark.skipif(
+    ON_WINDOWS,
+    reason="Very flaky on Windows CI. Can re-enable assuming it starts consistently passing.",
+)
 class TestZarrDirectoryStore(ZarrBase):
     @contextlib.contextmanager
     def create_zarr_target(self):
@@ -4459,14 +4463,14 @@
             with open_dataset(tmp, chunks=chunks) as dask_ds:
                 assert_identical(data, dask_ds)
                 with create_tmp_file() as tmp2:
                     dask_ds.to_netcdf(tmp2)
                     with open_dataset(tmp2) as on_disk:
                         assert_identical(data, on_disk)
 
     def test_deterministic_names(self) -> None:
         with create_tmp_file() as tmp:
             data = create_test_data()
             data.to_netcdf(tmp)
             with open_mfdataset(tmp, combine="by_coords") as ds:
                 original_names = {k: v.data.name for k, v in ds.data_vars.items()}
             with open_mfdataset(tmp, combine="by_coords") as ds:
@@ -4484,7 +4488,7 @@
         computed = actual.compute()
         assert not actual._in_memory
         assert computed._in_memory
         assert_allclose(actual, computed, decode_bytes=False)
 
     def test_save_mfdataset_compute_false_roundtrip(self) -> None:
         from dask.delayed import Delayed
@@ -4497,7 +4501,7 @@
                     datasets, [tmp1, tmp2], engine=self.engine, compute=False
                 )
                 assert isinstance(delayed_obj, Delayed)
                 delayed_obj.compute()
                 with open_mfdataset(
                     [tmp1, tmp2], combine="nested", concat_dim="x"
                 ) as actual:
@@ -4506,7 +4510,7 @@
     def test_load_dataset(self) -> None:
         with create_tmp_file() as tmp:
             original = Dataset({"foo": ("x", np.random.randn(10))})
             original.to_netcdf(tmp)
             ds = load_dataset(tmp)
             # this would fail if we used open_dataset instead of load_dataset
             ds.to_netcdf(tmp)
@@ -4514,7 +4518,7 @@
     def test_load_dataarray(self) -> None:
         with create_tmp_file() as tmp:
             original = Dataset({"foo": ("x", np.random.randn(10))})
             original.to_netcdf(tmp)
             ds = load_dataarray(tmp)
             # this would fail if we used open_dataarray instead of
             # load_dataarray
@@ -4527,7 +4531,7 @@
     def test_inline_array(self) -> None:
         with create_tmp_file() as tmp:
             original = Dataset({"foo": ("x", np.random.randn(10))})
             original.to_netcdf(tmp)
             chunks = {"time": 10}
 
             def num_graph_nodes(obj):
@@ -4580,7 +4584,7 @@
             yield actual, expected
 
     def test_cmp_local_file(self) -> None:
         with self.create_datasets() as (actual, expected):
             assert_equal(actual, expected)
 
             # global attributes should be global attributes on the dataset
@@ -4614,7 +4618,7 @@
 
     def test_compatible_to_netcdf(self) -> None:
         # make sure it can be saved as a netcdf
         with self.create_datasets() as (actual, expected):
             with create_tmp_file() as tmp_file:
                 actual.to_netcdf(tmp_file)
                 with open_dataset(tmp_file) as actual2:
@@ -4623,7 +4627,7 @@
 
     @requires_dask
     def test_dask(self) -> None:
         with self.create_datasets(chunks={"j": 2}) as (actual, expected):
             assert_equal(actual, expected)