1
1
import pystache
2
- from pyres import ResQ
2
+
3
+ from pyres import ResQ , __version__
3
4
from pyres .worker import Worker as Wrkr
4
5
import os
5
6
TEMPLATE_PATH = os .path .join (os .path .dirname (__file__ ), 'templates' )
@@ -12,6 +13,8 @@ def media_folder(self):
12
13
return '/media/'
13
14
def address (self ):
14
15
return '%s:%s' % (self .resq .redis .host ,self .resq .redis .port )
16
+ def version (self ):
17
+ return str (__version__ )
15
18
16
19
17
20
class Overview (ResWeb ):
@@ -224,9 +227,9 @@ def key_info(self):
224
227
for key in self .resq .keys ():
225
228
226
229
stats .append ({
227
- 'key' : key ,
228
- 'type' : self .resq .redis .get_type (key ),
229
- 'size' : redis_size (key , self .resq )
230
+ 'key' : str ( key ) ,
231
+ 'type' : str ( self .resq .redis .get_type ('resque:' + key ) ),
232
+ 'size' : str ( redis_size (key , self .resq ) )
230
233
})
231
234
return stats
232
235
def standard (self ):
@@ -251,18 +254,18 @@ def key_type(self):
251
254
def items (self ):
252
255
items = []
253
256
if self .key_type () == 'list' :
254
- for k in self .resq .redis .lrange (self .stat_id ,0 ,20 ):
257
+ for k in self .resq .redis .lrange ('resque:' + self .stat_id ,0 ,20 ):
255
258
items .append ({
256
259
'row' :str (k )
257
260
})
258
261
elif self .key_type () == 'set' :
259
- for k in self .resq .redis .smembers (self .stat_id ):
262
+ for k in self .resq .redis .smembers ('resque:' + self .stat_id ):
260
263
items .append ({
261
264
'row' :str (k )
262
265
})
263
266
elif self .key_type () == 'string' :
264
267
items .append ({
265
- 'row' :str (self .resq .redis .get (self .stat_id ))
268
+ 'row' :str (self .resq .redis .get ('resque:' + self .stat_id ))
266
269
})
267
270
return items
268
271
@@ -343,12 +346,12 @@ def runat(self):
343
346
"""
344
347
pass
345
348
def redis_size (key , resq ):
346
- key_type = resq .redis .get_type (key )
349
+ key_type = resq .redis .get_type ('resque:' + key )
347
350
item = 0
348
351
if key_type == 'list' :
349
- item = resq .redis .llen (key )
352
+ item = resq .redis .llen ('resque:' + key )
350
353
elif key_type == 'set' :
351
- item = resq .redis .scard (key )
354
+ item = resq .redis .scard ('resque:' + key )
352
355
elif key_type == 'string' :
353
356
item = 1
354
357
return str (item )
0 commit comments