Use the new Execution.create_all_from_jobs to perform_all_later

Author: rosa

app/models/solid_queue/job.rb

@@ -13,7 +13,7 @@ class SolidQueue::Job < SolidQueue::Record
   DEFAULT_QUEUE_NAME = "default"
 
   class << self
-    def enqueue_active_jobs(active_jobs)
+    def enqueue_all_active_jobs(active_jobs)
       scheduled_jobs, immediate_jobs = active_jobs.partition(&:scheduled_at)
       with_concurrency_limits, without_concurrency_limits = immediate_jobs.partition(&:concurrency_limited?)
 
@@ -23,18 +23,16 @@ def enqueue_active_jobs(active_jobs)
 
       transaction do
         job_rows = scheduled_jobs.map { |job| attributes_from_active_job(job) }
-        self.insert_all(job_rows)
+        insert_all(job_rows)
         inserted_jobs = where(active_job_id: scheduled_jobs.map(&:job_id))
-        execution_rows = inserted_jobs.map { |job| job.attributes.slice("queue_name", "priority", "scheduled_at").merge(job_id: job.id) }
-        SolidQueue::ScheduledExecution.insert_all(execution_rows)
+        SolidQueue::ScheduledExecution.create_all_from_jobs(inserted_jobs)
       end
 
       transaction do
         job_rows = without_concurrency_limits.map { |job| attributes_from_active_job(job) }
-        self.insert_all(job_rows)
+        insert_all(job_rows)
         inserted_jobs = where(active_job_id: without_concurrency_limits.map(&:job_id))
-        execution_rows = inserted_jobs.map { |job| job.attributes.slice("queue_name", "priority").merge(job_id: job.id) }
-        SolidQueue::ReadyExecution.insert_all(execution_rows)
+        SolidQueue::ReadyExecution.create_all_from_jobs(inserted_jobs)
       end
     end
 

lib/active_job/queue_adapters/solid_queue_adapter.rb

@@ -21,7 +21,7 @@ def enqueue_at(active_job, timestamp) # :nodoc:
       end
 
       def enqueue_all(active_jobs) # :nodoc:
-        SolidQueue::Job.enqueue_active_jobs(active_jobs)
+        SolidQueue::Job.enqueue_all_active_jobs(active_jobs)
       end
     end
   end