class OpenTelemetry::Instrumentation::Que::Middlewares::ServerMiddleware

def self.enhance_span_after_job_completion(span, job)

def self.enhance_span_after_job_completion(span, job)
  span.set_attribute('messaging.que.attempts', job.que_attrs[:error_count])
  error = job.que_error
  return unless error
  span.record_exception(error)
  span.status = OpenTelemetry::Trace::Status.error("Unhandled exception of type: #{error.class}")
end