在Delayed_job中手动重试作业

Question

延迟::作业的自动重试功能很棒,但我现在需要手动重试这项工作.有没有一种方法我可以在工作本身上调用...

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

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

这将在完成后删除作业.

Answer 3

您可以通过查找作业和运行执行来完全按照您所说的方式执行此操作.

但是,我通常只是将run_at设置回来,以便作业处理器再次选择它.

Answer 4

我在控制器中有一个用于测试目的的方法,当我点击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 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.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