We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5f45920 commit 665bff1Copy full SHA for 665bff1
app/models/solid_queue/claimed_execution.rb
@@ -11,7 +11,7 @@ class << self
11
def claiming(job_ids, process_id, &block)
12
job_data = Array(job_ids).collect { |job_id| { job_id: job_id, process_id: process_id } }
13
14
- insert_all(job_data)
+ insert_all!(job_data)
15
where(job_id: job_ids, process_id: process_id).load.tap do |claimed|
16
block.call(claimed)
17
SolidQueue.logger.info("[SolidQueue] Claimed #{claimed.size} jobs")
0 commit comments