lib/ci/queue/redis/base.rb in ci-queue-0.17.1 vs lib/ci/queue/redis/base.rb in ci-queue-0.17.2
- old
+ new
@@ -36,19 +36,19 @@
def progress
total - size
end
- def wait_for_master(timeout: 10)
+ def wait_for_master(timeout: 30)
return true if master?
(timeout * 10 + 1).to_i.times do
if queue_initialized?
return true
else
sleep 0.1
end
end
- raise LostMaster, "The master worker is still `#{master_status}` after 10 seconds waiting."
+ raise LostMaster, "The master worker is still `#{master_status}` after #{timeout} seconds waiting."
end
def workers_count
redis.scard(key('workers'))
end