Inline adapter should raise unhandled exceptions during execution

lib/good_job/adapter.rb

@@ -64,10 +64,12 @@ def enqueue_at(active_job, timestamp)
 
       if execute_inline?
         begin
-          execution.perform
+          result = execution.perform
         ensure
           execution.advisory_unlock
         end
+
+        raise result.unhandled_error if result.unhandled_error
       else
         job_state = { queue_name: execution.queue_name }
         job_state[:scheduled_at] = execution.scheduled_at if execution.scheduled_at

spec/integration/adapter_spec.rb

@@ -94,4 +94,28 @@ def perform(*_args, **_kwargs)
       end
     end
   end
+
+  context 'when inline adapter' do
+    let(:adapter) { GoodJob::Adapter.new(execution_mode: :inline) }
+
+    before do
+      stub_const 'PERFORMED', []
+      stub_const 'JobError', Class.new(StandardError)
+      stub_const 'TestJob', (Class.new(ActiveJob::Base) do
+        retry_on JobError, attempts: 3
+
+        def perform
+          PERFORMED << Time.current
+          raise JobError
+        end
+      end)
+    end
+
+    it 'raises unhandled exceptions' do
+      expect do
+        TestJob.perform_later
+      end.to raise_error JobError
+      expect(PERFORMED.size).to eq 3
+    end
+  end
 end

spec/lib/good_job/adapter_spec.rb

@@ -27,6 +27,33 @@
       )
     end
 
+    context 'when inline' do
+      let(:adapter) { described_class.new(execution_mode: :inline) }
+
+      before do
+        stub_const 'PERFORMED', []
+        stub_const 'JobError', Class.new(StandardError)
+        stub_const 'TestJob', (Class.new(ActiveJob::Base) do
+          def perform(succeed: true)
+            PERFORMED << Time.current
+
+            raise JobError unless succeed
+          end
+        end)
+      end
+
+      it 'executes the job immediately' do
+        adapter.enqueue(TestJob.new(succeed: true))
+        expect(PERFORMED.size).to eq 1
+      end
+
+      it "raises unhandled exceptions" do
+        expect do
+          adapter.enqueue(TestJob.new(succeed: false))
+        end.to raise_error(JobError)
+      end
+    end
+
     context 'when async' do
       it 'triggers an execution thread and the notifier' do
         allow(GoodJob::Execution).to receive(:enqueue).and_return(good_job)