lib/resque/worker.rb in resque-1.6.0 vs lib/resque/worker.rb in resque-1.6.1
- old
+ new
@@ -320,9 +320,10 @@
end
# Unregisters ourself as a worker. Useful when shutting down.
def unregister_worker
redis.srem(:workers, self)
+ redis.del("worker:#{self}")
redis.del("worker:#{self}:started")
Stat.clear("processed:#{self}")
Stat.clear("failed:#{self}")
end