Class: SourceMonitor::ImportSessionHealthCheckJob

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

Instance Method Summary collapse

Methods inherited from ApplicationJob

source_monitor_queue

Instance Method Details

#perform(import_session_id, entry_id) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'app/jobs/source_monitor/import_session_health_check_job.rb', line 14

def perform(import_session_id, entry_id)
  import_session = SourceMonitor::ImportSession.find_by(id: import_session_id)
  return unless import_session

  SourceMonitor::ImportSessions::HealthCheckUpdater.new(
    import_session: import_session,
    entry_id: entry_id
  ).call
rescue ActiveRecord::Deadlocked
  raise # re-raise so rescue_from handler catches it
rescue StandardError => error
  if defined?(Rails) && Rails.respond_to?(:logger) && Rails.logger
    Rails.logger.error(
      "[SourceMonitor::ImportSessionHealthCheckJob] #{error.class}: #{error.message}"
    )
  end
end