Report errors to the error reporter

Author: npezza93

lib/solid_queue/pool.rb

@@ -19,12 +19,10 @@ def post(execution)
       available_threads.decrement
 
       future = Concurrent::Future.new(args: [ execution ], executor: executor) do |thread_execution|
-        wrap_in_app_executor do
-          thread_execution.perform
-        ensure
-          available_threads.increment
-          mutex.synchronize { on_idle.try(:call) if idle? }
-        end
+        thread_execution.perform
+      ensure
+        available_threads.increment
+        mutex.synchronize { on_idle.try(:call) if idle? }
       end
 
       future.add_observer do |_, _, error|

test/unit/worker_test.rb

@@ -51,17 +51,15 @@ class WorkerTest < ActiveSupport::TestCase
     subscriber = ErrorBuffer.new
     Rails.error.subscribe(subscriber)
 
-    SolidQueue::ClaimedExecution::Result.expects(:new).raises(RuntimeError.new("everything is broken")).at_least_once
-
-    AddToBufferJob.perform_later "hey!"
+    RaisingJob.perform_later(RuntimeError, "B")
 
     @worker.start
 
     wait_for_jobs_to_finish_for(1.second)
     @worker.wake_up
 
     assert_equal 1, subscriber.errors.count
-    assert_equal "everything is broken", subscriber.messages.first
+    assert_equal "This is a RuntimeError exception", subscriber.messages.first
   ensure
     Rails.error.unsubscribe(subscriber) if Rails.error.respond_to?(:unsubscribe)
     SolidQueue.on_thread_error = original_on_thread_error