Class: DwcOccurrenceRefreshJob

Inherits:
ApplicationJob show all
Defined in:
app/jobs/dwc_occurrence_refresh_job.rb

Instance Method Summary collapse

Instance Method Details

#max_attempts ⇒ Object 



8
9
10
 
# File 'app/jobs/dwc_occurrence_refresh_job.rb', line 8

def max_attempts
  2
end

#max_run_time ⇒ Object 



4
5
6
 
# File 'app/jobs/dwc_occurrence_refresh_job.rb', line 4

def max_run_time
  2.hours
end

#perform(project_id: nil, user_id: nil) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'app/jobs/dwc_occurrence_refresh_job.rb', line 12

def perform(project_id: nil, user_id: nil)
  q = DwcOccurrence.where(project_id:, is_flagged_for_rebuild: true)

  Current.user_id = user_id
  q.all.find_each do |o|
    begin
      o.dwc_occurrence_object.send(:set_dwc_occurrence)
    rescue =>  ex
      ExceptionNotifier.notify_exception(
        ex,
        data: { project_id:, user_id:}
      )
      raise
    end
  end

end