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 2450594 commit 2e99a4dCopy full SHA for 2e99a4d
src/zarr/storage/_obstore.py
@@ -199,11 +199,14 @@ async def delete(self, key: str) -> None:
199
200
async def delete_dir(self, prefix: str) -> None:
201
# docstring inherited
202
+ import obstore as obs
203
+
204
self._check_writable()
205
if prefix != "" and not prefix.endswith("/"):
206
prefix += "/"
207
- keys = [(k,) async for k in self.list_prefix(prefix)]
208
+ metas = await obs.list(self.store, prefix).collect_async()
209
+ keys = [(m["path"],) for m in metas]
210
await concurrent_map(keys, self.delete, limit=config.get("async.concurrency"))
211
212
@property
0 commit comments