Skip to content
This repository has been archived by the owner on May 22, 2022. It is now read-only.

Commit

Permalink
Caches: Attempt to cast single get/set to str()
Browse files Browse the repository at this point in the history
get/set_multi was already casting keys to str()
  • Loading branch information
kemitche committed May 5, 2015
1 parent f92b3d1 commit aa77243
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions r2/r2/lib/cache.py
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ def retry(self, times, fn):
def get(self, key, default = None):
def do_get():
with self.clients.reserve() as mc:
ret = mc.get(key)
ret = mc.get(str(key))
if ret is None:
return default
return ret
Expand All @@ -153,7 +153,7 @@ def do_get_multi():
def set(self, key, val, time = 0):
def do_set():
with self.clients.reserve() as mc:
return mc.set(key, val, time = time,
return mc.set(str(key), val, time=time,
min_compress_len = self.min_compress_len)

return self.retry(self.timeout_retry, do_set)
Expand Down Expand Up @@ -187,24 +187,24 @@ def incr_multi(self, keys, prefix='', delta=1):

def append(self, key, val, time=0):
with self.clients.reserve() as mc:
return mc.append(key, val, time=time)
return mc.append(str(key), val, time=time)

def incr(self, key, delta=1, time=0):
# ignore the time on these
with self.clients.reserve() as mc:
return mc.incr(key, delta)
return mc.incr(str(key), delta)

def add(self, key, val, time=0):
try:
with self.clients.reserve() as mc:
return mc.add(key, val, time=time)
return mc.add(str(key), val, time=time)
except pylibmc.DataExists:
return None

def delete(self, key, time=0):
def do_delete():
with self.clients.reserve() as mc:
return mc.delete(key)
return mc.delete(str(key))

return self.retry(self.timeout_retry, do_delete)

Expand Down

0 comments on commit aa77243

Please sign in to comment.