test
This commit is contained in:
parent
4634e36eeb
commit
7e3af3599d
|
@ -62,6 +62,8 @@ class RedisPriorityQueue:
|
||||||
return self.redis.zcard('queue')
|
return self.redis.zcard('queue')
|
||||||
|
|
||||||
def len(self, model_name):
|
def len(self, model_name):
|
||||||
|
print(self.redis.zrange('queue', 0, -1))
|
||||||
|
|
||||||
count = 0
|
count = 0
|
||||||
for key in self.redis.zrange('queue', 0, -1):
|
for key in self.redis.zrange('queue', 0, -1):
|
||||||
item = json.loads(key)
|
item = json.loads(key)
|
||||||
|
|
Reference in New Issue