activejob/test/support/integration/adapters/delayed_job.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14

module DelayedJobJobsManager
  def clear_jobs
    Delayed::Job.delete_all
  end

  def start_workers
    @worker = Delayed::Worker.new(quiet: false, sleep_delay: 0.5)
    @thread = Thread.new { @worker.start }
  end

  def stop_workers
    @worker.stop
  end
end