Skip to content

Instantly share code, notes, and snippets.

@naveed-ahmad
Forked from wbotelhos/clear-sidekiq-jobs.sh
Last active March 17, 2019 20:48
Show Gist options
  • Save naveed-ahmad/3d52042138f4ded45d93ec3a06c4773c to your computer and use it in GitHub Desktop.
Save naveed-ahmad/3d52042138f4ded45d93ec3a06c4773c to your computer and use it in GitHub Desktop.
Clear Sidekiq Jobs
# 1. Clear retry set
Sidekiq::RetrySet.new.clear
# 2. Clear scheduled jobs
Sidekiq::ScheduledSet.new.clear
# 3. Clear 'Processed' and 'Failed' jobs
Sidekiq::Stats.new.reset
# 3. Clear 'Dead' jobs statistics
Sidekiq::DeadSet.new.clear
# Via API
require 'sidekiq/api'
stats = Sidekiq::Stats.new
stats.queues
# {"production_mailers"=>25, "production_default"=>1}
queue = Sidekiq::Queue.new('queue_name')
queue.count
queue.clear
# Retry failed jobs
Sidekiq::RetrySet.new.retry_all
@naveed-ahmad
Copy link
Author

naveed-ahmad commented Mar 17, 2019

Delete jobs for a specific class:

queue = Sidekiq::Queue.new

queue.each do |job|
  job.delete if job.item['class'] == 'ClassName'
end

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment