We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 08dc4f9 commit 6ad9a0aCopy full SHA for 6ad9a0a
src/zarr/storage/_fsspec.py
@@ -293,12 +293,8 @@ async def delete_dir(self, prefix: str) -> None:
293
294
path_to_delete = _dereference_path(self.path, prefix)
295
296
- # this is probably the same condition as `if self.fs.async_impl`
297
- if hasattr(self.fs, "_rm") and inspect.iscoroutinefunction(self.fs._rm):
298
- with suppress(*self.allowed_exceptions):
299
- await self.fs._rm(path_to_delete, recursive=True)
300
- else:
301
- raise NotImplementedError("The store does not support async deletes")
+ with suppress(*self.allowed_exceptions):
+ await self.fs._rm(path_to_delete, recursive=True)
302
303
async def exists(self, key: str) -> bool:
304
# docstring inherited
0 commit comments