以后用resque-scheduler创建Resque作业,怎么单元测试?
将任务排入队列的代码:
i = 0
installed_apps.each_slice(3) do |slice|
slice.each do |installed_app_id|
Resque.enqueue_in((5*i).minutes, ReinstallApp, installed_app_id)
end
i = i+1
end
用于在单元测试中手动运行常规 Rescue 任务的代码:
def run_worker_simulation
worker = Resque::Worker.new('connection')
job = worker.reserve
worker.perform(job)
end
当作为常规 Resque 作业排队时,该任务运行良好。问题是这不会运行任何 resque-scheduler 计划任务,即使是具有 Resque.enqueue_in(0.minutes, ...) 的任务。您如何手动运行计划任务?