Задержка задания: сконфигурируйте run_at и max_attempts для определенного задания

Question

Мне нужно перезаписать Delayed::Worker.max_attempts для одного конкретного задания, которое я хочу повторить много раз. Кроме того, я не хочу, чтобы следующее запланированное время определялось экспоненциально (из документов: 5 секунд + N ** 4, где N - количество попыток).

Я не хочу перезаписывать настройки Delayed::Worker и влиять на другие задания.

Моя работа уже является настраиваемой работой (я обрабатываю ошибки определенным образом), так что это может быть полезно. Любые указатели на то, как это сделать?

Answer 1

Я понял, просмотрев delayed_job Исходный код. Это не документировано нигде в своих документах.

Вот что я сделал:

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 

Надеется, что это поможет кому-то в будущем.