Class: SolidQueue::Record

Inherits:
ActiveRecord::Base
  • Object
show all
Defined in:
app/models/solid_queue/record.rb

Direct Known Subclasses

Execution, Job, Pause, Process, RecurringTask, Semaphore

Class Method Summary collapse

Class Method Details

.non_blocking_lock ⇒ Object 



10
11
12
13
14
15
16
 
# File 'app/models/solid_queue/record.rb', line 10

def non_blocking_lock
  if SolidQueue.use_skip_locked
    lock(Arel.sql("FOR UPDATE SKIP LOCKED"))
  else
    lock
  end
end

.supports_insert_conflict_target? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
21
22
 
# File 'app/models/solid_queue/record.rb', line 18

def supports_insert_conflict_target?
  connection_pool.with_connection do |connection|
    connection.supports_insert_conflict_target?
  end
end