Module: Que::Scheduler::Db

Defined in:
lib/que/scheduler/db.rb

Constant Summary collapse

SCHEDULER_COUNT_SQL = 
"SELECT COUNT(*) FROM que_jobs WHERE job_class = 'Que::Scheduler::SchedulerJob'"
NOW_SQL = 
"SELECT now()"

Class Method Summary collapse

Class Method Details

.count_schedulers ⇒ Object 



13
14
15
 
# File 'lib/que/scheduler/db.rb', line 13

def count_schedulers
  Que::Scheduler::VersionSupport.execute(SCHEDULER_COUNT_SQL).first.values.first.to_i
end

.now ⇒ Object 



17
18
19
 
# File 'lib/que/scheduler/db.rb', line 17

def now
  Que::Scheduler::VersionSupport.execute(NOW_SQL).first.values.first
end

.transaction ⇒ Object

rubocop:disable Style/ExplicitBlockArgument



22
23
24
 
# File 'lib/que/scheduler/db.rb', line 22

def transaction
  Que::Scheduler.configuration.transaction_adapter.call { yield }
end