Skip to content

Instantly share code, notes, and snippets.

@otaq
Last active January 3, 2016 00:51
Show Gist options
  • Save otaq/6b210d44b82589a3eee9 to your computer and use it in GitHub Desktop.
Save otaq/6b210d44b82589a3eee9 to your computer and use it in GitHub Desktop.
Sidekiq
# To reset processed jobs:
Sidekiq.redis { |c| c.del('stat:processed') }
# and to reset failed jobs:
Sidekiq.redis { |c| c.del('stat:failed') }
# See workers
Sidekiq::Client.registered_workers
# See queues
Sidekiq::Client.registered_queues
# See all jobs for one queue
Sidekiq.redis { |r| r.lrange "queue:app_queue", 0, -1 }
# See all jobs in all queues
Sidekiq::Client.registered_queues.each do |q|
Sidekiq.redis { |r| r.lrange "queue:#{q}", 0, -1 }
end
# Remove a queue and all of its jobs
Sidekiq.redis do |r|
r.srem "queues", "app_queue"
r.del "queue:app_queue"
end
queue = Sidekiq::Queue.new("export")
queue.each do |job|
job.klass # => 'MyWorker'
job.args # => [1, 2, 3]
job.delete if job.jid == 'abcdef1234567890'
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment