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