feat: Add rake task to clear ActionCable jobs (#9307)
This commit is contained in:
17
lib/tasks/sidekiq_tasks.rake
Normal file
17
lib/tasks/sidekiq_tasks.rake
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
namespace :sidekiq do
|
||||||
|
desc "Clear ActionCableJobs from sidekiq's critical queue"
|
||||||
|
task clear_action_cable_broadcast_jobs: :environment do
|
||||||
|
queue_name = 'critical'
|
||||||
|
queue = Sidekiq::Queue.new(queue_name)
|
||||||
|
jobs_cleared = 0
|
||||||
|
|
||||||
|
queue.each do |job|
|
||||||
|
if job['wrapped'] == 'ActionCableBroadcastJob'
|
||||||
|
job.delete
|
||||||
|
jobs_cleared += 1
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
puts "Cleared #{jobs_cleared} ActionCableBroadcastJob(s) from the #{queue_name} queue."
|
||||||
|
end
|
||||||
|
end
|
||||||
Reference in New Issue
Block a user