如何使用 Sidekiq::RetrySet 重试 N 个作业?
How to retry N jobs using Sidekiq::RetrySet?
我用过
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 }
我用过
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 }