blocks|key|978966|text|手动调用作业的步骤|type|unstyled|depth|inlineStyleRanges|entityRanges|data|978967|Delayed::Job.find(10).invoke_job+#+10+is+the+job.id|code-block|syntax|javascript|978968|如果作业成功运行，则不会删除该作业。您需要手动删除它：|978969|Delayed::Job.find(10).destroy|978970|entityMap^0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|N|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|O|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|P|8|@]|9|@]|A|$E|F]]|$1|K|3|-4|5|6|7|Q|8|@]|9|@]|A|$]]]|L|$]]

To manually call a job

<pre><code>Delayed::Job.find(10).invoke_job # 10 is the job.id
</code></pre>

This does not remove the job if it is run successfully. You need to remove it manually:

<pre><code>Delayed::Job.find(10).destroy
</code></pre>

blocks|key|979224|text|Delayed::Worker.new.run(Delayed::Job.last)|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|979225|这将在作业完成后删除该作业。|unstyled|979226|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$B|C]]|$1|D|3|E|5|F|7|J|8|@]|9|@]|A|$]]|$1|G|3|-4|5|F|7|K|8|@]|9|@]|A|$]]]|H|$]]

<pre><code>Delayed::Worker.new.run(Delayed::Job.last)
</code></pre>

This will remove the job after it is done.

blocks|key|978936|text|您可以完全按照您所说的方式进行操作，即找到作业并运行perform。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|978937|但是，我通常只是将run_at设置回原处，以便job+processor再次拾取它。|978938|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|F|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|G|8|@]|9|@]|A|$]]|$1|D|3|-4|5|6|7|H|8|@]|9|@]|A|$]]]|E|$]]

You can do it exactly the way you said, by finding the job and running perform.

However, what I generally do is just set the run_at back so the job processor picks it up again.

blocks|key|1193300|text|我在控制器中有一个用于测试目的的方法，当我命中URL时，该方法仅重置所有延迟的作业。不是特别优雅，但对我来说很好用：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1193301|#+For+testing+purposes
++def+reset_all_jobs
++++Delayed::Job.all.each+do+%7Cdj%7C
++++++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|code-block|syntax|javascript|1193302|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

I have a method in a controller for testing purposes that just resets all delayed jobs when I hit a URL. Not super elegant but works great for me:

<pre><code># 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
</code></pre>

blocks|key|1193423|text|上面之前的答案可能已经过时了。我发现我需要将failed_at、locked_by和locked_at设置为零：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1193424|(对于要重试的每个作业)：|1193425|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!|code-block|syntax|javascript|1193426|entityMap^0|0|0|0^^$0|@$1|2|3|4|5|6|7|K|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|L|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|M|8|@]|9|@]|A|$G|H]]|$1|I|3|-4|5|6|7|N|8|@]|9|@]|A|$]]]|J|$]]

Prior answers above might be out of date. I found I needed to set failed_at, locked_by, and locked_at to nil:

(for each job you want to retry):

<pre><code>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!
</code></pre>

blocks|key|1193606|text|如果您失败了需要重新运行的延迟作业，则只需选择它们，并将所有引用失败重试的内容设置为null：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1193607|Delayed::Job.where("last_error+is+not+null").each+do+%7Cdj%7C
++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|code-block|syntax|javascript|1193608|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

if you have failed delayed job which you need to re-run, then you will need to only select them and set everything refer to failed retry to null:

<pre><code>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
</code></pre>

blocks|key|1193352|text|在开发环境中，遵循Joe+Martinez的建议，通过rails+console重试所有延迟的作业的好方法是：|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|1193353|Delayed::Job.all.each{%7Cd%7C+d.run_at+=+Time.now;+d.save!}|code-block|syntax|javascript|1193354|entityMap^0|R|D|0|0^^$0|@$1|2|3|4|5|6|7|M|8|@$9|N|A|O|B|C]]|D|@]|E|$]]|$1|F|3|G|5|H|7|P|8|@]|D|@]|E|$I|J]]|$1|K|3|-4|5|6|7|Q|8|@]|D|@]|E|$]]]|L|$]]

In a development environment, through <code>rails console</code>, following Joe Martinez's suggestion, a good way to retry all your delayed jobs is:

<pre><code>Delayed::Job.all.each{|d| d.run_at = Time.now; d.save!}
</code></pre>

blocks|key|1193437|text|Delayed::Job.all.each(&:invoke_job)|type|code-block|depth|inlineStyleRanges|entityRanges|data|syntax|javascript|1193438|unstyled|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|G|8|@]|9|@]|A|$B|C]]|$1|D|3|-4|5|E|7|H|8|@]|9|@]|A|$]]]|F|$]]

<pre><code>Delayed::Job.all.each(&amp;:invoke_job)
</code></pre>

blocks|key|1193677|text|把它放在一个初始化器文件中！|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1193678|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|code-block|syntax|javascript|1193679|然后就可以运行Delayed::Job.find(1234).retry!了|offset|length|style|CODE|1193680|这基本上会将作业放回队列中并正常处理它。|1193681|entityMap^0|0|0|7|U|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|R|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|S|8|@$I|T|J|U|K|L]]|9|@]|A|$]]|$1|M|3|N|5|6|7|V|8|@]|9|@]|A|$]]|$1|O|3|-4|5|6|7|W|8|@]|9|@]|A|$]]]|P|$]]

Put this in an initializer file!

<pre><code>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
</code></pre>

Then you can run <code>Delayed::Job.find(1234).retry!</code> 

This will basically stick the job back into the queue and process it normally.

Delayed::Job's auto-retry feature is great, but there's a job that I want to manually retry now. Is there a method I can call on the job itself like...

<pre><code>Delayed::Job.all[0].perform
</code></pre>

or run, or something. I tried a few things, and combed the documentation, but couldn't figure out how to execute a manual retry of a job.

Manually Retry Job in Delayed_job

延迟：：作业的自动重试功能很棒，但现在有一个作业我想手动重试。有没有一种方法可以调用作业本身，就像...Delayed::Job.all[0].perform或者跑，或者别的什么。我尝试了一些方法，并梳理了文档，但不知道如何执行作业的手动重试。

问在Delayed_job中手动重试作业
EN

回答 9

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在Delayed_job中手动重试作业EN

回答 9

Stack Overflow用户

Stack Overflow用户

Stack Overflow用户

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问在Delayed_job中手动重试作业
EN