Delayed_job中手动重试作业

Question

Delayed :: Job的自动重试功能非常好，但我现在需要手动重试。有没有一种方法，我可以打电话给工作本身就像...

Delayed::Job.all[0].perform 

或运行，或其他。我尝试了几件事情，并梳理了文档，但无法弄清楚如何执行手动重试作业。

Answer 1

手动调用工作

Delayed::Job.find(10).invoke_job # 10 is the job.id 

如果成功运行该不会删除工作。您需要手动删除它：

Delayed::Job.find(10).destroy 

Answer 2

您可以通过查找作业和执行作业完全按照您的说法进行作业。

但是，我通常所做的只是将run_at设置回来，以便作业处理器再次选取它。

Answer 3

我在控制器中有一个方法用于测试目的，当我点击一个URL时重置所有延迟的作业。不是超级优雅，但对我的作品很大：

# For testing purposes 
    def reset_all_jobs 
    Delayed::Job.all.each do |dj| 
     dj.run_at = Time.now - 1.day 
     dj.locked_at = nil 
     dj.locked_by = nil 
     dj.attempts = 0 
     dj.last_error = nil 
     dj.save 
    end 
    head :ok 
    end 

Answer 4

在开发环境中，通过rails console，继乔·马丁内斯的建议，重新尝试所有的延迟就业的好方法是：

Delayed::Job.all.each{|d| d.run_at = Time.now; d.save!} 

Answer 5

上述现有答案可能已过时。我发现我需要设置failed_at，locked_by和locked_at为nil：

（对于要重试每个作业）：

d.last_error = nil 
d.run_at = Time.now 
d.failed_at = nil 
d.locked_at = nil 
d.locked_by = nil 
d.attempts = 0 
d.failed_at = nil # needed in Rails 5/delayed_job (4.1.2) 
d.save! 

Answer 6

Delayed::Job.all.each(&:invoke_job) 

Answer 7

Delayed::Worker.new.run(Delayed::Job.last) 

这将删除作业后，它是完成。

Answer 8

，如果你失败了，你需要重新运行延误的工作，那么你只需要选择它们并设置就绪指未能重试空：

Delayed::Job.where("last_error is not null").each do |dj| 
    dj.run_at = Time.now.advance(seconds: 5) 
    dj.locked_at = nil 
    dj.locked_by = nil 
    dj.attempts = 0 
    dj.last_error = nil 
    dj.failed_at = nil 
    dj.save 
end 

Answer 9

在初始化文件将这个！

module Delayed 
    module Backend 
    module ActiveRecord 
     class Job 
     def retry! 
      self.run_at = Time.now - 1.day 
      self.locked_at = nil 
      self.locked_by = nil 
      self.attempts = 0 
      self.last_error = nil 
      self.failed_at = nil 
      self.save! 
     end 
     end 
    end 
    end 
end 

然后你可以运行Delayed::Job.find(1234).retry!

这基本上都会坚持工作回到队列中，通常对其进行处理。