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!

這基本上都會堅持工作回到隊列中，通常對其進行處理。