Last active
January 3, 2016 00:51
-
-
Save otaq/6b210d44b82589a3eee9 to your computer and use it in GitHub Desktop.
Sidekiq
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
# 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