class SidekiqUniqueJobs::Orphans::Observer

def update(time, result, ex)

Returns:
  • () -

Parameters:
  • ex (Exception) -- any error raised from the TimerTask
  • result (Object) -- the result of the execution
  • time (Time) -- the time of the execution 
def update(time, result, ex)
  if result
    log_info("(#{time}) Execution successfully returned #{result}")
  elsif ex.is_a?(Concurrent::TimeoutError)
    log_warn("(#{time}) Execution timed out")
  else
    log_info("(#{time}) Cleanup failed with error #{ex.message}")
    log_error(ex)
  end
end