2020-06-02 20:13:38 +02:00
|
|
|
class ApiEntreprise::Job < ApplicationJob
|
2020-09-22 17:14:31 +02:00
|
|
|
queue_as :api_entreprise
|
|
|
|
|
2020-12-02 17:17:00 +01:00
|
|
|
retry_on ApiEntreprise::API::ServiceUnavailable,
|
|
|
|
ApiEntreprise::API::BadGateway,
|
|
|
|
wait: 1.day
|
|
|
|
|
2020-12-03 10:39:51 +01:00
|
|
|
retry_on ApiEntreprise::API::TimedOut, wait: :exponentially_longer
|
|
|
|
|
2020-06-02 20:13:38 +02:00
|
|
|
DEFAULT_MAX_ATTEMPTS_API_ENTREPRISE_JOBS = 5
|
2020-06-11 23:09:50 +02:00
|
|
|
|
2020-09-28 14:37:34 +02:00
|
|
|
# If by the time the job runs the Etablissement has been deleted
|
|
|
|
# (it can happen through EtablissementUpdateJob for instance), ignore the job
|
|
|
|
discard_on ActiveRecord::RecordNotFound
|
|
|
|
|
2020-06-11 23:09:50 +02:00
|
|
|
rescue_from(ApiEntreprise::API::ResourceNotFound) do |exception|
|
|
|
|
error(self, exception)
|
|
|
|
end
|
|
|
|
|
|
|
|
rescue_from(ApiEntreprise::API::BadFormatRequest) do |exception|
|
|
|
|
error(self, exception)
|
|
|
|
end
|
|
|
|
|
2020-07-07 16:56:13 +02:00
|
|
|
def error(job, exception)
|
|
|
|
# override ApplicationJob#error to avoid reporting to sentry
|
|
|
|
end
|
|
|
|
|
2020-06-02 20:13:38 +02:00
|
|
|
def max_attempts
|
2020-06-16 15:47:24 +02:00
|
|
|
ENV.fetch("MAX_ATTEMPTS_API_ENTREPRISE_JOBS", DEFAULT_MAX_ATTEMPTS_API_ENTREPRISE_JOBS).to_i
|
2020-06-02 20:13:38 +02:00
|
|
|
end
|
|
|
|
end
|