lib/backburner/worker.rb in backburner-allq-1.0.45 vs lib/backburner/worker.rb in backburner-allq-1.0.46
- old
+ new
@@ -189,10 +189,9 @@
retry_status = "failed: attempt #{num_retries+1} of #{max_job_retries+1}"
if num_retries < max_job_retries # retry again
retry_delay = resolve_retry_delay(job.job_class)
delay = resolve_retry_delay_proc(job.job_class).call(retry_delay, num_retries) rescue retry_delay
-log_error("Delay should be #{delay}")
job.retry(num_retries + 1, delay)
log_job_end(job.name, "#{retry_status}, retrying in #{delay}s") if job_started_at
else # retries failed, bury
job.bury
log_job_end(job.name, "#{retry_status}, burying") if job_started_at