重試前sidekiq更新參數

Question

如何在重試之前更新活動作業參數？我有一份需要持久性存儲的作業，因此我將其數據作爲參數存儲到作業（散列）中，並在每項作業完成後更新數據。如果作業失敗，我想用更新的數據重試，而不是用於計劃作業的數據。

我使用sidekiq安排我的工作順便說一句。

問候。

Answer 1

您需要使用修改的參數挽救並創建一個新作業。 Sidekiq不允許你修改工作人員的工作。

def perform(a) 
    begin 
    do_work 
    rescue SomeError 
    self.class.perform_async(a+1) 
    end 
end