Active jobのretryの検証

ソース

# frozen_string_literal: true class RetryTestJob < ActiveJob::Base class RetryOnlyDoError < StandardError; end class RetryRailseExceptionError < StandardError; end class RetryWithoutProcessError < StandardError; end class DiscardError < StandardError; end FILENAME = "#{Rails.root.to_s}/tmp/jobtest.txt" queue_as :high discard_on StandardError do |job, e| RetryTestJob.write_file("retry_on", job.job_id, job.executions, "#{e.class}: #{e.message}") end # attempts が０になっても何も行わない retry_on RetryWithoutProcessError, wait: 1.seconds, attempts: 3 # attempts が０になった場合に処理を行う retry_on(RetryOnlyDoError, wait: 1.seconds, attempts: 2) do |job, e| RetryTestJob.write_file("retry_on", job.job_id, job.executions, "#{e.class}: #{e.message}") end # 無限にRetryしてしまう retry_on(RetryRailseExceptionError, wait: 1.seconds, attempts: 2) do |job, e| RetryTestJob.write_file("retry_on", job.job_id, job.executions, "#{e.class}: #{e.message}") raise StandardError, "raise StandardError from retry_on: #{job.executions}, #{e.message}" end def perform RetryTestJob.write_file("perform", job_id, executions) # 確認したいエラーに切り替える # error = StandardError error = RetryOnlyDoError # error = RetryRailseExceptionError # error = RetryWithoutProcessError raise error, "raise #{error.name} from perform: #{job_id}, #{executions}" end private def self.write_file(action, job_id, executions, message=nil) File.open(FILENAME, 'a') { |f| f.write("#{action}[#{job_id}, #{executions}]#{message ? ": #{message}" : ""}\n") } end end

結果

StandardError の場合

perform[fdf6cc91-2f25-4c9c-ac7c-aedbe2202bea, 1] retry_on[fdf6cc91-2f25-4c9c-ac7c-aedbe2202bea, 1]: StandardError: raise StandardError from perform: fdf6cc91-2f25-4c9c-ac7c-aedbe2202bea, 1

RetryOnlyDoError の場合

perform[304646d3-649d-422c-9b04-0b0f551f49c7, 1] perform[304646d3-649d-422c-9b04-0b0f551f49c7, 2] retry_on[304646d3-649d-422c-9b04-0b0f551f49c7, 2]: RetryTestJob::RetryOnlyDoError: raise RetryTestJob::RetryOnlyDoError from perform: 304646d3-649d-422c-9b04-0b0f551f49c7, 2

RetryRailseExceptionError の場合

retry_on 内でエラーが発生した場合は、無限に実行されるので気をつける。

perform[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 1] perform[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2] retry_on[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2]: RetryTestJob::RetryRailseExceptionError: raise RetryTestJob::RetryRailseExceptionError from perform: bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2 perform[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2] retry_on[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2]: RetryTestJob::RetryRailseExceptionError: raise RetryTestJob::RetryRailseExceptionError from perform: bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2 perform[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2] retry_on[bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2]: RetryTestJob::RetryRailseExceptionError: raise RetryTestJob::RetryRailseExceptionError from perform: bff00afd-a3a1-4bf4-93ed-987ed600bed8, 2

RetryWithoutProcessError

perform[aae6bf69-422d-44b2-b575-e7d425f0e976, 1] perform[aae6bf69-422d-44b2-b575-e7d425f0e976, 2] perform[aae6bf69-422d-44b2-b575-e7d425f0e976, 3]