sidekiq Update-Parameter vor dem erneuten Versuch

Question

Wie kann ich einen aktiven Job-Parameter vor dem erneuten Versuch aktualisieren? Ich habe einen Job, der permanenten Speicher benötigt, also speichere ich seine Daten als Argument für den Job (Hash) und die Daten werden nach jedem Job aktualisiert. Wenn der Job fehlschlägt, möchte ich die aktualisierten Daten anstelle der Daten, die zum Planen des Jobs verwendet wurden, erneut versuchen.

Ich benutze sidekiq für die Planung meiner Jobs btw.

Grüße.

Answer 1

Sie müssen einen neuen Job retten und mit dem geänderten Parameter erstellen. Sidekiq erlaubt es Ihnen nicht, einen Job vom Worker zu ändern.

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