Module: Delayed::Testing
- Defined in:
- lib/delayed/testing.rb
Class Method Summary collapse
Class Method Details
.clear_all! ⇒ Object
22 23 24 25 26 27 28 29 30 |
# File 'lib/delayed/testing.rb', line 22 def self.clear_all! case Delayed::Job.name when /Redis/ Delayed::Job.redis.flushdb when /ActiveRecord/ Delayed::Job.delete_all Delayed::Job::Failed.delete_all end end |
.drain ⇒ Object
7 8 9 10 11 12 13 14 15 |
# File 'lib/delayed/testing.rb', line 7 def self.drain while job = Delayed::Job.get_and_lock_next_available( 'spec run_jobs', Delayed::Settings.queue, 0, Delayed::MAX_PRIORITY) run_job(job) end end |
.run_job(job) ⇒ Object
3 4 5 |
# File 'lib/delayed/testing.rb', line 3 def self.run_job(job) Delayed::Worker.new.perform(job) end |
.track_created ⇒ Object
17 18 19 20 |
# File 'lib/delayed/testing.rb', line 17 def self.track_created job_tracking = JobTracking.track { yield } job_tracking.created end |