Commit3231e03

and

authored

Backport PR#3310: obstore delete_dir (#3437)

Co-authored-by: Kenneth Li <kli@sescollc.com>

1 parent8b00b94 commit3231e03Copy full SHA for 3231e03

File tree

+14

-0

lines changed

+14

-0

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+Add obstore implementation of delete_dir.`

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,7 @@`
`13`	`13`	`Store,`
`14`	`14`	`SuffixByteRequest,`
`15`	`15`	`)`
	`16`	`+fromzarr.core.commonimportconcurrent_map`
`16`	`17`	`fromzarr.core.configimportconfig`
`17`	`18`
`18`	`19`	`ifTYPE_CHECKING:`
`@@ -196,6 +197,18 @@ async def delete(self, key: str) -> None:`
`196`	`197`	`withcontextlib.suppress(FileNotFoundError):`
`197`	`198`	`awaitobs.delete_async(self.store,key)`
`198`	`199`
	`200`	`+asyncdefdelete_dir(self,prefix:str)->None:`
	`201`	`+# docstring inherited`
	`202`	`+importobstoreasobs`
	`203`	`+`
	`204`	`+self._check_writable()`
	`205`	`+ifprefix!=""andnotprefix.endswith("/"):`
	`206`	`+prefix+="/"`
	`207`	`+`
	`208`	`+metas=awaitobs.list(self.store,prefix).collect_async()`
	`209`	`+keys= [(m["path"],)forminmetas]`
	`210`	`+awaitconcurrent_map(keys,self.delete,limit=config.get("async.concurrency"))`
	`211`	`+`
`199`	`212`	`@property`
`200`	`213`	`defsupports_partial_writes(self)->bool:`
`201`	`214`	`# docstring inherited`

Comments

(0)