Add new log messages to good job log subscriber

Author: Taucher2003

lib/sagittarius/middleware/good_job/log_subscriber.rb

@@ -118,6 +118,32 @@ def cleanup_preserved_jobs(event)
           end
         end
 
+        def enqueue_concurrency_limit_exceeded(event)
+          job = event.payload[:job]
+          in_context do
+            logger.info(
+              message: 'Aborted enqueue of job because concurrency key has reached enqueue limit',
+              job_class: job.class.name,
+              execution_id: job.id,
+              concurrency_key: event.payload[:key],
+              concurrency_limit: event.payload[:limit]
+            )
+          end
+        end
+
+        def enqueue_concurrency_throttle_exceeded(event)
+          job = event.payload[:job]
+          in_context do
+            logger.info(
+              message: 'Aborted enqueue of job because concurrency key has reached throttle limit',
+              job_class: job.class.name,
+              execution_id: job.id,
+              concurrency_key: event.payload[:key],
+              concurrency_limit: event.payload[:limit]
+            )
+          end
+        end
+
         def systemd_watchdog_start(event)
           in_context { logger.info(message: 'Pinging systemd watchdog', interval_s: event.payload[:interval]) }
         end

spec/application_state_spec.rb

@@ -20,6 +20,17 @@
 
   describe 'good_job' do
     it { expect(GoodJob.migrated?).to be true }
+
+    it 'log subscriber overrides all log messages' do
+      ignored_overrides = %i[info fatal debug unknown error warn logger]
+
+      GoodJob::LogSubscriber.instance_methods(false).each do |method|
+        next if ignored_overrides.include?(method)
+
+        expect(Sagittarius::Middleware::GoodJob::LogSubscriber.method_defined?(method, false))
+          .to be(true), "#{Sagittarius::Middleware::GoodJob::LogSubscriber} should define #{method}"
+      end
+    end
   end
 end
 # rubocop:enable RSpec/DescribeClass