We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3ef37c8 commit 7d956dbCopy full SHA for 7d956db
ruby/lib/ci/queue/redis/worker.rb
@@ -212,12 +212,10 @@ def push(tests)
212
begin
213
redis.multi do |transaction|
214
transaction.lpush(key('queue'), tests) unless tests.empty?
215
- transaction.set(key('total'), @total)
216
- transaction.set(key('master-status'), 'ready')
+ transaction.set(key('total'), @total, ex: config.redis_ttl)
+ transaction.set(key('master-status'), 'ready', ex: config.redis_ttl)
217
218
transaction.expire(key('queue'), config.redis_ttl)
219
- transaction.expire(key('total'), config.redis_ttl)
220
- transaction.expire(key('master-status'), config.redis_ttl)
221
end
222
rescue ::Redis::BaseError, RedisClient::Error => error
223
if !queue_initialized? && attempts < 3
0 commit comments