@@ -30,8 +30,7 @@ def register_worker(self):
3030 self .resq .redis .sadd ('resque:workers' ,str (self ))
3131 #self.resq._redis.add("worker:#{self}:started", Time.now.to_s)
3232 self .started = datetime .datetime .now ()
33- #Stat.clear("processed:#{self}")
34- #Stat.clear("failed:#{self}")
33+
3534
3635 def _set_started (self , time ):
3736 if time :
@@ -51,6 +50,8 @@ def _get_started(self):
5150 def unregister_worker (self ):
5251 self .resq .redis .srem ('resque:workers' ,str (self ))
5352 self .started = None
53+ Stat ("processed:%s" % self ).clear ()
54+ Stat ("failed:%s" % self ).clear ()
5455
5556 def startup (self ):
5657 self .register_signal_handlers ()
@@ -161,13 +162,12 @@ def get_processed(self):
161162 return Stat ("processed:%s" % str (self ), self .resq ).get ()
162163
163164 def failed (self ):
164- total_failed = Stat ("failed" , self .resq )
165- stat = Stat ("failed:%s" % self , self .resq )
166- total_failed .incr ()
167- stat .incr ()
165+ Stat ("failed" , self .resq ).incr ()
166+ Stat ("failed:%s" % self , self .resq ).incr ()
168167
169168 def get_failed (self ):
170169 return Stat ("failed:%s" % self , self .resq ).get ()
170+
171171 def job (self ):
172172 data = self .resq .redis .get ("resque:worker:%s" % self )
173173 if data :
0 commit comments