@@ -108,11 +108,11 @@ def contains_group(store, prefix=None):
108
108
return group_attrs_key (prefix ) in store
109
109
110
110
111
- def rm (store , prefix = None ):
111
+ def rmdir (store , prefix = None ):
112
112
"""TODO"""
113
113
prefix = normalize_prefix (prefix )
114
- if hasattr (store , 'rm ' ):
115
- store .rm (prefix )
114
+ if hasattr (store , 'rmdir ' ):
115
+ store .rmdir (prefix )
116
116
else :
117
117
for key in set (store .keys ()):
118
118
if key .startswith (prefix ):
@@ -214,7 +214,7 @@ def init_array(store, shape, chunks, dtype=None, compression='default',
214
214
# guard conditions
215
215
if overwrite :
216
216
# attempt to delete any pre-existing items in store
217
- rm (store , prefix )
217
+ rmdir (store , prefix )
218
218
elif contains_array (store , prefix ):
219
219
raise ValueError ('store contains an array' )
220
220
elif contains_group (store , prefix ):
@@ -264,7 +264,7 @@ def init_group(store, overwrite=False, prefix=None):
264
264
# guard conditions
265
265
if overwrite :
266
266
# attempt to delete any pre-existing items in store
267
- rm (store , prefix )
267
+ rmdir (store , prefix )
268
268
elif contains_array (store , prefix ):
269
269
raise ValueError ('store contains an array' )
270
270
elif contains_group (store , prefix ):
@@ -322,7 +322,7 @@ class DirectoryStore(MutableMapping):
322
322
['a', 'foo']
323
323
>>> store.listdir('a/b')
324
324
['c']
325
- >>> store.rm ('a')
325
+ >>> store.rmdir ('a')
326
326
>>> sorted(store.keys())
327
327
['foo']
328
328
>>> import os
@@ -419,7 +419,7 @@ def listdir(self, prefix):
419
419
path = os .path .join (self .path , normalize_prefix (prefix ))
420
420
return sorted (os .listdir (path ))
421
421
422
- def rm (self , prefix ):
422
+ def rmdir (self , prefix ):
423
423
path = os .path .join (self .path , normalize_prefix (prefix ))
424
424
if os .path .isdir (path ):
425
425
shutil .rmtree (path )
@@ -504,7 +504,7 @@ def listdir(self, prefix):
504
504
prefix = normalize_prefix (prefix )
505
505
return _listdir_from_keys (self , prefix )
506
506
507
- def rm (self , prefix ):
507
+ def rmdir (self , prefix ):
508
508
raise NotImplementedError
509
509
510
510
def getsize (self , prefix ):
0 commit comments