fix RemoteStore._exists

Author: brokkoli71

src/zarr/store/remote.py

@@ -9,6 +9,7 @@
 from zarr.buffer import BufferPrototype
 from zarr.common import AccessModeLiteral
 from zarr.store.core import _dereference_path
+from zarr.sync import RuntimeSyncError
 
 if TYPE_CHECKING:
     from fsspec.asyn import AsyncFileSystem
@@ -88,6 +89,8 @@ def _exists(self) -> bool:
             return bool(self._fs.exists(self.path))
         except self.allowed_exceptions:
             return False
+        except RuntimeSyncError:
+            return False
 
     def __str__(self) -> str:
         return f"{self._url}"

src/zarr/sync.py

@@ -31,6 +31,10 @@ class SyncError(Exception):
     pass
 
 
+class RuntimeSyncError(RuntimeError):
+    pass
+
+
 def _get_lock() -> threading.Lock:
     """Allocate or return a threading lock.
 
@@ -72,7 +76,7 @@ def sync(
     if not isinstance(loop, asyncio.AbstractEventLoop):
         raise TypeError(f"loop cannot be of type {type(loop)}")
     if loop.is_closed():
-        raise RuntimeError("Loop is not running")
+        raise RuntimeSyncError("Loop is not running")
     try:
         loop0 = asyncio.events.get_running_loop()
         if loop0 is loop:

tests/v3/test_sync.py

@@ -4,7 +4,7 @@
 
 import pytest
 
-from zarr.sync import SyncError, SyncMixin, _get_lock, _get_loop, sync
+from zarr.sync import RuntimeSyncError, SyncError, SyncMixin, _get_lock, _get_loop, sync
 
 
 @pytest.fixture(params=[True, False])
@@ -67,7 +67,7 @@ def test_sync_raises_if_loop_is_closed() -> None:
 
     foo = AsyncMock(return_value="foo")
     with patch.object(loop, "is_closed", return_value=True):
-        with pytest.raises(RuntimeError):
+        with pytest.raises(RuntimeSyncError):
             sync(foo(), loop=loop)
     foo.assert_not_awaited()