Skip to content

Instantly share code, notes, and snippets.

View mjrusso's full-sized avatar

Michael Russo mjrusso

View GitHub Profile
# pyres ResQ list_range
def list_range(self, key, start, count, decode=True):
items = self.redis.lrange(key, start,start+count-1) or []
ret_list = []
for i in items:
if decode: i = ResQ.decode(i)
ret_list.append(i)
return ret_list
# pyres/failure/redis.py
@classmethod
def all(cls, resq, start=0, count=1):
items = resq.redis.lrange('resque:failed', start, count) or []
ret_list = []
for i in items:
failure = ResQ.decode(i)
failure['redis_value'] = base64.b64encode(i)
ret_list.append(failure)