rs = Sidekiq::RetrySet.new
rs.select { |job| job.args[0]['job_class'] == 'SomeNameSpace::SomeModule::SomeClassName' && job.args[0]['arguments'][0] == 'target job arg.' }
.sample(remaining_1_count)
.each { |job| job.delete }
반응형
rs = Sidekiq::RetrySet.new
rs.select { |job| job.args[0]['job_class'] == 'SomeNameSpace::SomeModule::SomeClassName' && job.args[0]['arguments'][0] == 'target job arg.' }
.sample(remaining_1_count)
.each { |job| job.delete }