Skip tests which use threading from stdlib

Author: agriyakhetarpal

zarr/tests/test_sync.py

@@ -8,6 +8,7 @@
 
 import numpy as np
 from numpy.testing import assert_array_equal
+import pytest
 
 from zarr.attrs import Attributes
 from zarr.core import Array
@@ -19,6 +20,7 @@
 from zarr.tests.test_attrs import TestAttributes, zarr_version  # noqa
 from zarr.tests.test_core import TestArray
 from zarr.tests.test_hierarchy import TestGroup
+from zarr.tests.util import is_wasm
 
 
 class TestAttributesWithThreadSynchronizer(TestAttributes):
@@ -95,7 +97,7 @@ def test_parallel_append(self):
 
         pool.terminate()
 
-
+@pytest.mark.skipif(is_wasm(), reason="No threading support in WASM/Pyodide")
 class TestArrayWithThreadSynchronizer(TestArray, MixinArraySyncTests):
     def create_array(self, read_only=False, **kwargs):
         store = KVStore(dict())
@@ -148,6 +150,7 @@ def test_hexdigest(self):
         assert "05b0663ffe1785f38d3a459dec17e57a18f254af" == z.hexdigest()
 
 
+@pytest.mark.skipif(is_wasm(), reason="No threading support in WASM/Pyodide")
 class TestArrayWithProcessSynchronizer(TestArray, MixinArraySyncTests):
     def create_array(self, read_only=False, **kwargs):
         path = tempfile.mkdtemp()
@@ -221,6 +224,7 @@ def _require_group(arg):
     return h.name
 
 
+@pytest.mark.skipif(is_wasm(), reason="No multiprocessing support in WASM/Pyodide")
 class MixinGroupSyncTests:
     def test_parallel_create_group(self):
         # setup
@@ -259,6 +263,7 @@ def test_parallel_require_group(self):
         pool.terminate()
 
 
+@pytest.mark.skipif(is_wasm(), reason="No threading support in WASM/Pyodide")
 class TestGroupWithThreadSynchronizer(TestGroup, MixinGroupSyncTests):
     def create_group(
         self, store=None, path=None, read_only=False, chunk_store=None, synchronizer=None
@@ -286,6 +291,7 @@ def test_synchronizer_property(self):
         assert isinstance(g.synchronizer, ThreadSynchronizer)
 
 
+@pytest.mark.skipif(is_wasm(), reason="No threading support in WASM/Pyodide")
 class TestGroupWithProcessSynchronizer(TestGroup, MixinGroupSyncTests):
     def create_store(self):
         path = tempfile.mkdtemp()