lib/rector/backends/redis.rb in rector-0.0.4 vs lib/rector/backends/redis.rb in rector-0.0.5
- old
+ new
@@ -39,11 +39,11 @@
def finish_worker(worker_id)
redis.srem(WORKER_LIST_SET, worker_id)
end
- def workers_working?
- redis.scard(WORKER_LIST_SET).to_i > 0
+ def num_workers_working
+ redis.scard(WORKER_LIST_SET).to_i
end
def cleanup
redis.del(*keys)
redis.del(KEY_LIST_SET, WORKER_LIST_SET)