Contents

require 'redis'
require 'resque'

if ARGV.size != 1
  puts "migrate_to_timestamps_set.rb <redis-host:redis-port>"
  exit
end

Resque.redis = ARGV[0]
redis = Resque.redis
Array(redis.keys("delayed:*")).each do |key|
  jobs = redis.lrange(key, 0, -1)
  jobs.each {|job| redis.sadd("timestamps:#{job}", key)}
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
resque-scheduler-2.5.5	script/migrate_to_timestamps_set.rb
resque-scheduler-2.5.4	script/migrate_to_timestamps_set.rb
resque-scheduler-2.5.3	script/migrate_to_timestamps_set.rb
resque-scheduler-2.5.2	script/migrate_to_timestamps_set.rb
resque-scheduler-2.5.1	script/migrate_to_timestamps_set.rb
resque-scheduler-2.5.0	script/migrate_to_timestamps_set.rb
resque-scheduler-2.4.0	script/migrate_to_timestamps_set.rb
resque-scheduler-2.3.1	script/migrate_to_timestamps_set.rb
resque-scheduler-2.3.0	script/migrate_to_timestamps_set.rb
resque-scheduler-2.2.0	script/migrate_to_timestamps_set.rb
resque-scheduler-2.1.1	script/migrate_to_timestamps_set.rb
resque-scheduler-2.1.0	script/migrate_to_timestamps_set.rb