2016-09-18 7 views
0

再試行する前にアクティブなジョブパラメータを更新するにはどうすればよいですか?私はいくつかの永続的なストレージを必要とする仕事を持っているので、そのデータをジョブ(ハッシュ)への引数として保存し、各ジョブの後にデータが更新されます。ジョブが失敗した場合、ジョブのスケジュールに使用されたデータではなく、更新されたデータで再試行します。sidekiq再試行前のパラメータを更新する

私の仕事をスケジューリングするのにsidekiqを使用しています。

よろしくお願いいたします。

答えて

0

修正されたパラメータで新しいジョブを救済して作成する必要があります。 Sidekiqでは、ワーカーからジョブを変更することはできません。

def perform(a) 
    begin 
    do_work 
    rescue SomeError 
    self.class.perform_async(a+1) 
    end 
end 
関連する問題