Dont cache if local
This commit is contained in:
parent
4d87edd995
commit
49646dfafa
@ -52,16 +52,20 @@ class CachedStorage(Storage):
|
|||||||
|
|
||||||
def _open(self, name, mode='rb'):
|
def _open(self, name, mode='rb'):
|
||||||
assert 'r' in mode, "Can only open for reading"
|
assert 'r' in mode, "Can only open for reading"
|
||||||
p = self._cached(name)
|
p = self.path(name)
|
||||||
return open(p, mode)
|
return open(p, mode)
|
||||||
|
|
||||||
def path(self, name):
|
def path(self, name):
|
||||||
return self._cached(name)
|
try:
|
||||||
|
return self.remote.path(name)
|
||||||
|
except NotImplementedError:
|
||||||
|
return self._cached(name)
|
||||||
|
|
||||||
def save(self, name, content, max_length=None):
|
def save(self, name, content, max_length=None):
|
||||||
p = self._filepath(name)
|
p = self._filepath(name)
|
||||||
if os.path.exists(p):
|
if os.path.exists(p):
|
||||||
os.unlink(p)
|
os.unlink(p)
|
||||||
|
# TODO: cache content to p
|
||||||
return self.remote.save(name, content, max_length)
|
return self.remote.save(name, content, max_length)
|
||||||
|
|
||||||
def delete(self, name):
|
def delete(self, name):
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user