Module: RocketJob::Plugins::Retry

Extended by:
ActiveSupport::Concern
Included in:
Jobs::CopyFileJob, Jobs::OnDemandBatchJob, Jobs::OnDemandJob
Defined in:
lib/rocket_job/plugins/retry.rb

Overview

Automatically retry the job on failure.

Example:

class MyJob < RocketJob::Job

include RocketJob::Plugins::Retry

# Set the maximum number of times a job should be retried before giving up.
self.retry_limit = 3

def perform
  puts "DONE"
end

end

# Queue the job for processing using the default cron_schedule specified above MyJob.create!

# Override the default retry_limit for a specific job instance. MyCronJob.create!(retry_limit: 10)

# Disable retries for this job instance. MyCronJob.create!(retry_limit: 0)

Below is a table of the delay for each retry attempt, as well as the total duration spent retrying a job for the specified number of retries, excluding actual processing time.

|———|————|—————-| | Attempt | Delay | Total Duration | |———|————|—————-| | 01 | 6.000s | 6.000s | | 02 | 21.000s | 27.000s | | 03 | 1m 26s | 1m 53s | | 04 | 4m 21s | 6m 14s | | 05 | 10m 30s | 16m 44s | | 06 | 21m 41s | 38m 25s | | 07 | 40m 6s | 20h 18m | | 08 | 20h 8m | 21h 26m | | 09 | 20h 49m | 23h 16m | | 10 | 21h 46m | 2h 3m | | 11 | 23h 4m | 6h 7m | | 12 | 0h 45m | 11h 52m | | 13 | 2h 56m | 1d 19h 48m | | 14 | 5h 40m | 1d 6h 29m | | 15 | 9h 3m | 2d 20h 33m | | 16 | 13h 12m | 2d 14h 45m | | 17 | 18h 12m | 3d 13h 57m | | 18 | 1d 0h 9m | 5d 19h 7m | | 19 | 1d 7h 12m | 6d 7h 19m | | 20 | 1d 15h 26m | 8d 3h 46m | | 21 | 2d 1h 1m | 10d 9h 47m | | 22 | 2d 12h 4m | 13d 2h 51m | | 23 | 3d 0h 44m | 16d 8h 35m | | 24 | 3d 15h 9m | 20d 4h 45m | | 25 | 4d 7h 30m | 24d 17h 16 | | 26 | 5d 1h 56m | 30d 0h 12m | | 27 | 6d 22h 37m | 36d 3h 49m | | 28 | 7d 21h 44m | 43d 6h 34m | | 29 | 8d 23h 28m | 51d 11h 2m | | 30 | 9d 4h 0m | 61d 20h 2m | |———|————|—————-|

Instance Method Summary collapse

Instance Method Details

#rocket_job_failure_count ⇒ Object 



87
88
89
 
# File 'lib/rocket_job/plugins/retry.rb', line 87

def rocket_job_failure_count
  failed_at_list.size
end

#rocket_job_retry_on_fail? ⇒ Boolean

Returns [true|false] whether this job should be retried on failure.

Returns:

  • (Boolean) 


83
84
85
 
# File 'lib/rocket_job/plugins/retry.rb', line 83

def rocket_job_retry_on_fail?
  rocket_job_failure_count < retry_limit
end