Add temporary additional lock on good_jobs-[active_job_id]

lib/good_job/job.rb

@@ -163,7 +163,13 @@ def self.perform_with_advisory_lock
         break if good_job.blank?
         break :unlocked unless good_job&.executable?
 
-        good_job.perform
+        begin
+          good_job.with_advisory_lock(key: "good_jobs-#{good_job.active_job_id}") do
+            good_job.perform
+          end
+        rescue RecordAlreadyAdvisoryLockedError => e
+          ExecutionResult.new(value: nil, handled_error: e)
+        end
       end
     end
 

spec/integration/scheduler_spec.rb

@@ -18,8 +18,10 @@
       def perform(*_args, **_kwargs)
         thread_name = Thread.current.name || Thread.current.object_id
 
+        expected_locks_per_thread = 2 # TODO: Temporary value for GoodJob v1.99. Should be reduced to 1 for GoodJob 2.0.
+
         locks_count = PgLock.advisory_lock.owns.count
-        if locks_count > 1
+        if locks_count > expected_locks_per_thread
           puts "Thread #{thread_name} owns #{locks_count} locks."
 
           puts "GoodJobs locked by this connection:"