【发布时间】:2017-12-12 07:16:55
【问题描述】:
我用过
Sidekiq::RetrySet.new.retry_all
这会重试我所有失败的工作。 我有 10 000 个失败的工作,只想重试前 20 或 30 个
@query = Sidekiq::RetrySet.new
@test = @query.select[1..20] do |job|
job.retry
end
你怎么看?
【问题讨论】:
我用过
Sidekiq::RetrySet.new.retry_all
这会重试我所有失败的工作。 我有 10 000 个失败的工作,只想重试前 20 或 30 个
@query = Sidekiq::RetrySet.new
@test = @query.select[1..20] do |job|
job.retry
end
你怎么看?
【问题讨论】:
您的示例不起作用,但Sidekiq::RetrySet 确实包含Enumerable,因此您可以执行以下操作:
Sidekiq::RetrySet.new.first(20).each { |job| job.retry }
【讨论】: