Module: Submission::DelayedJobBehaviour

Included in:
Submission
Defined in:
app/models/submission/delayed_job_behaviour.rb

Overview

rubocop:todo Style/Documentation

Instance Method Summary collapse

Instance Method Details

#build_batch ⇒ Object 


11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'app/models/submission/delayed_job_behaviour.rb', line 11

def build_batch
  ActiveRecord::Base.transaction do
    finalize_build!
  end
rescue ActiveRecord::StatementInvalid => e
  # If an SQL problems occurs, it's more likely that's it's
  # a one shot one, e.g. timeout , deadlock etc ...
  # So we don't want the submission to fail but the delayed job to
  # retry later. Therefore the DelayedJob should fail
  raise e
rescue ActiveRecord::RecordInvalid, Submission::ProjectValidation::Error => e
  Rails.logger.error(e.message)
  Rails.logger.error(e.backtrace)
  fail_set_message_and_save(e.message)
rescue => e
  Rails.logger.error(e.message)
  Rails.logger.error(e.backtrace)
  fail_set_message_and_save("#{e.message}\n#{e.backtrace.join("\n")}")
end

#default_priority ⇒ Object 


2
3
4
 
# File 'app/models/submission/delayed_job_behaviour.rb', line 2

def default_priority
  configatron.delayed_job.fetch(:submission_process_priority, 0)
end

#finalize_build! ⇒ Object 


31
32
33
34
 
# File 'app/models/submission/delayed_job_behaviour.rb', line 31

def finalize_build!
  process!
  ready!
end

#queue_submission_builder ⇒ Object 


6
7
8
9
 
# File 'app/models/submission/delayed_job_behaviour.rb', line 6

def queue_submission_builder
  # Lower priorities get processed faster. This ensures high priority submissions get processed first.
  Delayed::Job.enqueue SubmissionBuilderJob.new(id), priority: default_priority - priority
end