Reintentar manualmente el trabajo en Delayed_job

Question

Retrasado :: La función de reintento automático del trabajo es excelente, pero hay un trabajo que deseo reintentar manualmente ahora. ¿Existe algún método al que pueda llamar en el trabajo como ...

Delayed::Job.all[0].perform 

o ejecutar, o algo así. Probé algunas cosas y analicé la documentación, pero no pude encontrar la manera de ejecutar un intento manual de un trabajo.

Answer 1

Para llamar manualmente un trabajo

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

Esto no elimina el trabajo si se ejecuta correctamente. Es necesario eliminar de forma manual:

Delayed::Job.find(10).destroy 

Answer 2

Puede hacerlo exactamente como lo dijo, encontrando el trabajo y ejecutándolo.

Sin embargo, lo que generalmente hago es simplemente configurar el run_at para que el procesador de tareas lo recupere nuevamente.

Answer 3

tengo un método en un controlador para propósitos de prueba que solo restablece todos los puestos de trabajo con retraso cuando llegué a una dirección URL. No es muy elegante, pero funciona muy bien para mí:

# 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

En un entorno de desarrollo, a través de rails console, siguiendo la sugerencia de Joe Martínez, una buena manera de volver a intentar todos los trabajos de retraso es:

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

Answer 5

respuestas previas anteriores podría estar desactualizado He encontrado que necesitaba para establecer failed_at, locked_by y locked_at a cero:

(para cada trabajo que desea volver a intentar):

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) 

Esto eliminará el trabajo después de que se hecho.

Answer 8

si ha fallado trabajo retrasado los que es necesario volver a ejecutar, a continuación, tendrá que seleccionar solamente ellos y establece que todo se refiere a reintento fallado en nulo:

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

poner esto en un fichero de inicialización!

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 

continuación, puede ejecutar Delayed::Job.find(1234).retry!

Esto se adhieren básicamente el trabajo de nuevo en la cola y procesarlo con normalidad.