squash: add additional error handling

instrumentation/active_job/lib/opentelemetry/instrumentation/active_job/instrumentation.rb

@@ -69,6 +69,7 @@ def require_dependencies
 
         def patch_activejob
           ::ActiveJob::Base.prepend(Patches::Base) unless ::ActiveJob::Base.ancestors.include?(Patches::Base)
+
           Subscriber.install
         end
       end

instrumentation/active_job/lib/opentelemetry/instrumentation/active_job/patches/base.rb

@@ -13,6 +13,20 @@ module Base
           def self.prepended(base)
             base.class_eval do
               attr_accessor :__otel_headers
+
+              around_perform do |_job, block|
+                block.call
+              rescue StandardError => e
+                begin
+                  span = OpenTelemetry::Trace.current_span
+                  span.record_exception(e)
+                  span.status = OpenTelemetry::Trace::Status.error(e.message)
+                rescue StandardError => ignore
+                  OpenTelemetry.handle_error(ignore)
+                end
+
+                raise e
+              end
             end
           end
 

instrumentation/active_job/test/instrumentation/active_job/patches/active_job_callbacks_test.rb

@@ -73,20 +73,20 @@
     end
   end
 
-  # describe 'exception handling' do
-    # it 'sets span status to error' do
-      # _{ ExceptionJob.perform_later }.must_raise StandardError, 'This job raises an exception'
-      # _(process_span.status.code).must_equal OpenTelemetry::Trace::Status::ERROR
-      # _(process_span.status.description).must_equal 'Unhandled exception of type: StandardError'
-    # end
+  describe 'exception handling' do
+    it 'sets span status to error' do
+      _ { ExceptionJob.perform_later }.must_raise StandardError, 'This job raises an exception'
+      _(process_span.status.code).must_equal OpenTelemetry::Trace::Status::ERROR
+      _(process_span.status.description).must_equal 'This job raises an exception'
+    end
 
-    # it 'records the exception' do
-      # _ { ExceptionJob.perform_now }.must_raise StandardError, 'This job raises an exception'
-      # _(process_span.events.first.name).must_equal 'exception'
-      # _(process_span.events.first.attributes['exception.type']).must_equal 'StandardError'
-      # _(process_span.events.first.attributes['exception.message']).must_equal 'This job raises an exception'
-    # end
-  # end
+    it 'records the exception' do
+      _ { ExceptionJob.perform_now }.must_raise StandardError, 'This job raises an exception'
+      _(process_span.events.first.name).must_equal 'exception'
+      _(process_span.events.first.attributes['exception.type']).must_equal 'StandardError'
+      _(process_span.events.first.attributes['exception.message']).must_equal 'This job raises an exception'
+    end
+  end
 
   describe 'span kind' do
     it 'sets correct span kinds for inline jobs' do