Lavoro ritardato: configurare run_at e max_attempts per un lavoro specifico

Question

Devo sovrascrivere lo Delayed::Worker.max_attempts per un lavoro specifico, che desidero riprovare molte volte. Inoltre, non voglio che il prossimo orario pianificato venga determinato in modo esponenziale (dai documenti: 5 secondi + N ** 4, dove N è il numero di tentativi).

Non voglio sovrascrivere le impostazioni Delayed::Worker e influire su altri lavori.

Il mio lavoro è già un lavoro personalizzato (gestisco gli errori in un certo modo), quindi potrebbe essere utile. Qualche suggerimento su come farlo?

Answer 1

L'ho scoperto esaminando il codice sorgente delayed_job. Questo non è documentato da nessuna parte nei loro documenti.

Ecco quello che ho fatto:

class MyCustomJob < Struct.new(:param1, :param2) 
    def perform 
    # do something 
    end 

    # attempts and time params are required by delayed_job 
    def reschedule_at(time, attempts) 
    30.seconds.from_now 
    end 

    def max_attempts 
    50 
    end 
end 

Spero che questo aiuti qualcuno in futuro.