Class: Form1010cg::SubmissionJob
- Inherits:
-
Object
- Object
- Form1010cg::SubmissionJob
- Includes:
- SentryLogging, Sidekiq::Job, Sidekiq::MonitoredWorker
- Defined in:
- app/sidekiq/form1010cg/submission_job.rb
Constant Summary collapse
- STATSD_KEY_PREFIX =
"#{Form1010cg::Auditor::STATSD_KEY_PREFIX}.async.".freeze
Instance Method Summary collapse
Methods included from SentryLogging
#log_exception_to_sentry, #log_message_to_sentry, #non_nil_hash?, #normalize_level, #rails_logger
Instance Method Details
#notify(params) ⇒ Object
22 23 24 |
# File 'app/sidekiq/form1010cg/submission_job.rb', line 22 def notify(params) StatsD.increment("#{STATSD_KEY_PREFIX}failed_ten_retries", tags: ["params:#{params}"]) end |
#perform(claim_id) ⇒ Object
26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 |
# File 'app/sidekiq/form1010cg/submission_job.rb', line 26 def perform(claim_id) claim = SavedClaim::CaregiversAssistanceClaim.find(claim_id) Form1010cg::Service.new(claim).process_claim_v2! begin claim.destroy! rescue => e log_exception_to_sentry(e) end rescue CARMA::Client::MuleSoftClient::RecordParseError StatsD.increment("#{STATSD_KEY_PREFIX}record_parse_error", tags: ["claim_id:#{claim_id}"]) rescue StatsD.increment("#{STATSD_KEY_PREFIX}retries") increment_applications_retried(claim_id) raise end |
#retry_limits_for_notification ⇒ Object
18 19 20 |
# File 'app/sidekiq/form1010cg/submission_job.rb', line 18 def retry_limits_for_notification [10] end |