Store expires_at time in blocked_executions

We'll use this to improve the queries performed by the concurrency
maintenance task.

Author: rosa

app/models/solid_queue/blocked_execution.rb

@@ -1,6 +1,7 @@
 module SolidQueue
   class BlockedExecution < SolidQueue::Execution
     assume_attributes_from_job :concurrency_key
+    before_create :set_expires_at
 
     has_one :semaphore, foreign_key: :key, primary_key: :concurrency_key
 
@@ -34,6 +35,10 @@ def release
     end
 
     private
+      def set_expires_at
+        self.expires_at = job.concurrency_duration.from_now
+      end
+
       def acquire_concurrency_lock
         Semaphore.wait(job)
       end

db/migrate/20231103204612_create_solid_queue_concurrency_controls.rb

@@ -12,8 +12,10 @@ def change
       t.string :concurrency_key, null: false
 
       t.datetime :created_at, null: false
+      t.datetime :expires_at, null: false
 
       t.index [ :concurrency_key, :priority, :job_id ], name: "index_solid_queue_blocked_executions_for_release"
+      t.index [ :expires_at, :concurrency_key ], name: "index_solid_queue_blocked_executions_for_maintenance"
     end
 
     create_table :solid_queue_semaphores do |t|

test/dummy/db/schema.rb

@@ -25,7 +25,9 @@
     t.integer "priority", default: 0, null: false
     t.string "concurrency_key", null: false
     t.datetime "created_at", null: false
+    t.datetime "expires_at", null: false
     t.index ["concurrency_key", "priority", "job_id"], name: "index_solid_queue_blocked_executions_for_release"
+    t.index ["expires_at", "concurrency_key"], name: "index_solid_queue_blocked_executions_for_maintenance"
     t.index ["job_id"], name: "index_solid_queue_blocked_executions_on_job_id", unique: true
   end
 

test/models/solid_queue/job_test.rb

@@ -93,6 +93,9 @@ class NonOverlappingGroupedJob2 < NonOverlappingJob
     assert_blocked do
       NonOverlappingJob.perform_later(@result, name: "B")
     end
+
+    blocked_execution = SolidQueue::BlockedExecution.last
+    assert blocked_execution.expires_at <= SolidQueue.default_concurrency_control_period.from_now
   end
 
   private