Fix IdentityJobLogSubscriber exception_class

lib/identity_job_log_subscriber.rb

@@ -9,7 +9,7 @@ def enqueue(event)
     json = default_attributes(event, job)
 
     if ex
-      json[:exception_class] = ex.class
+      json[:exception_class] = ex.class.name
       json[:exception_message] = ex.message
 
       error(json.to_json)
@@ -29,7 +29,7 @@ def enqueue_at(event)
     json = default_attributes(event, job)
 
     if ex
-      json[:exception_class] = ex.class
+      json[:exception_class] = ex.class.name
       json[:exception_message] = ex.message
 
       error(json.to_json)
@@ -65,7 +65,7 @@ def perform(event)
 
     if ex
       # NewRelic?
-      json[:exception_class] = ex.class
+      json[:exception_class] = ex.class.name
       json[:exception_message] = ex.message
       json[:exception_backtrace] = Array(ex.backtrace).join("\n")
 
@@ -88,7 +88,7 @@ def enqueue_retry(event)
       wait_ms: wait.to_i.in_milliseconds,
     }
 
-    json[:exception_class] = ex.class if ex
+    json[:exception_class] = ex.class.name if ex
 
     info(json.to_json)
   end
@@ -98,7 +98,7 @@ def retry_stopped(event)
     ex = event.payload[:error]
 
     json = default_attributes(event, job).merge(
-      exception_class: ex.class,
+      exception_class: ex.class.name,
       attempts: job.executions,
     )
 

spec/lib/identity_job_log_subscriber_spec.rb

@@ -42,6 +42,7 @@
       expect(json.key?('duration_ms'))
       expect(json.key?('job_id'))
       expect(json.key?('timestamp'))
+      expect(json['exception_class']).to eq('ArgumentError')
       expect(json['exception_message']).to eq 'invalid base64'
     end