Sha256: 0a22ff642f3488192a1fae343bc1c07121e98d73dd08b4d28ec9b18a0d4ffa57
Contents?: true
Size: 958 Bytes
Versions: 10
Compression:
Stored size: 958 Bytes
Contents
When /^I run the delayed jobs$/ do
unless @resque_worker
@resque_worker = Resque::Worker.new("ts_delta")
@resque_worker.register_worker
end
while job = @resque_worker.reserve
@resque_worker.perform(job)
end
end
When /^I run one delayed job$/ do
unless @resque_worker
@resque_worker = Resque::Worker.new("ts_delta")
@resque_worker.register_worker
end
job = @resque_worker.reserve
@resque_worker.perform(job)
end
When /^I cancel the jobs$/ do
ThinkingSphinx::Deltas::ResqueDelta.clear!
end
When /^I change the name of delayed beta (\w+) to (\w+)$/ do |current, replacement|
DelayedBeta.find_by_name(current).update_attributes(:name => replacement)
end
Then /^there should be no more DeltaJobs on the Resque queue$/ do
job_classes = Resque.redis.lrange("queue:ts_delta", 0, -1).collect do |j|
Resque.decode(j)["class"]
end
job_classes.should_not include("ThinkingSphinx::Deltas::ResqueDelta::DeltaJob")
end
Version data entries
10 entries across 10 versions & 2 rubygems