Ręczne ponawianie pracy w trybie Delayed_job

Question

Opóźnienie: funkcja automatycznego powtarzania zadania jest świetna, ale istnieje zadanie, które chcę ręcznie spróbować ponownie. Czy istnieje sposób, w jaki mogę zadzwonić do samego zadania, jak ...

Delayed::Job.all[0].perform 

lub uruchomić, lub coś. Próbowałem kilku rzeczy i przeczesywałem dokumentację, ale nie mogłem wymyślić, jak wykonać ręczną próbę wykonania pracy.

Answer 1

Aby ręcznie wywołać pracę

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

nie usunąć zadanie, jeśli jest prowadzony z powodzeniem. Musisz usunąć go ręcznie:

Answer 2

Możesz zrobić to dokładnie tak, jak powiedziałeś, znajdując pracę i wykonując przedstawienie.

Zazwyczaj jednak ustawię parametr run_at, aby procesor roboczy odtworzył go ponownie.

Answer 3

Mam metodę w kontroler do celów testowych, który po prostu resetuje wszystkie opóźnione zadania, gdy uderzyłem w adres URL. Nie bardzo eleganckie, ale działa świetnie dla mnie:

# 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

W środowisku rozwoju, poprzez rails console, po sugestii Joe Martineza, to dobry sposób, aby ponowić wszystkie opóźnione pracy jest:

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

Answer 5

Prior odpowiedzi Powyższe może być nieaktualny. Uważam, że muszę ustawić failed_at, locked_by i locked_at do zera:

(dla każdego zadania, które ma ponowić próbę):

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) 

To usunie zadanie po jego Gotowe.

Answer 8

jeśli zawiodły opóźnione zadanie, które trzeba ponownie uruchomić, a następnie trzeba będzie je tylko wybrać i ustawić wszystko odnosi się do nieudanej ponownego null:

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

umieścić to w pliku inicjatora!

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 

Następnie można uruchomić Delayed::Job.find(1234).retry!

to będzie w zasadzie trzymać pracę z powrotem do kolejki i przetwarza je normalnie.