test/test_helper.rb in resque-retry-1.7.4 vs test/test_helper.rb in resque-retry-1.7.5

- old
+ new

@@ -18,29 +18,33 @@ require 'mocha/setup' require 'resque-retry' require dir + '/test_jobs' -# make sure we can run redis-server -if !system('which redis-server') - puts '', "** `redis-server` was not found in your PATH" - abort '' -end +if ENV['CI'] != 'true' + # make sure we can run redis-server + if !system('which redis-server') + puts '', "** `redis-server` was not found in your PATH" + abort '' + end -# make sure we can shutdown the server using cli. -if !system('which redis-cli') - puts '', "** `redis-cli` was not found in your PATH" - abort '' -end + # make sure we can shutdown the server using cli. + if !system('which redis-cli') + puts '', "** `redis-cli` was not found in your PATH" + abort '' + end -# This code is run after all the tests have finished running to ensure that the -# Redis server is shutdowa -Minitest.after_run { `redis-cli -p 9736 shutdown nosave` } + # This code is run after all the tests have finished running to ensure that the + # Redis server is shutdowa + Minitest.after_run { `redis-cli -p 9736 shutdown nosave` } -puts "Starting redis for testing at localhost:9736..." -`redis-server #{dir}/redis-test.conf` -Resque.redis = '127.0.0.1:9736' + puts "Starting redis for testing at localhost:9736..." + `redis-server #{dir}/redis-test.conf` + Resque.redis = '127.0.0.1:9736' +else + Resque.redis = '127.0.0.1:6379' +end # Test helpers class Minitest::Test def perform_next_job(worker, &block) return unless job = worker.reserve @@ -63,14 +67,14 @@ end end def delayed_jobs # The double-checks here are so that we won't blow up if the config stops using redis-namespace - timestamps = Resque.redis.zrange("resque:delayed_queue_schedule", 0, -1) + + timestamps = Resque.redis.zrange("resque:delayed_queue_schedule", 0, -1) + Resque.redis.zrange("delayed_queue_schedule", 0, -1) delayed_jobs_as_json = timestamps.map do |timestamp| - Resque.redis.lrange("resque:delayed:#{timestamp}", 0, -1) + + Resque.redis.lrange("resque:delayed:#{timestamp}", 0, -1) + Resque.redis.lrange("delayed:#{timestamp}", 0, -1) end.flatten delayed_jobs_as_json.map { |json| JSON.parse(json) } end