我正在玩delayed_job,我需要删除所有的作业与一个指定的处理程序值,我尝试这样
class Auction < ActiveRecord::Base
def clean_jobs
Delayed::Job.all.each do |job|
job.delete if job.payload_object.auction_id == id
end
end
end
它的工作,但我必须通过整个队列…不是很酷.我该如何解决这个问题？
谢谢
解决方法
您正在使用payload_object,它是一个YAML文本.
可能这个代码做同样的事情.
Delayed::Job.where("handler LIKE '%auction_id: #{id}%'").delete_all
并进行双重检查：
Delayed::Job.where("handler LIKE '%auction_id: #{id}%'").each do |job|
job.delete if job.payload_object.auction_id == id
end