Sha256: 70a085d96458342c311c641af56bcc46416c474a5d758c861577da1324d78d95

Contents?: true

Size: 354 Bytes

Versions: 8

Compression:

Stored size: 354 Bytes

Contents

# vim:fileencoding=utf-8

require 'redis'
require 'resque_admin'

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

ResqueAdmin.redis = ARGV[0]
redis = ResqueAdmin.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

8 entries across 8 versions & 2 rubygems

Version Path
resque_admin-scheduler-1.2.0 bin/migrate_to_timestamps_set.rb
resque_admin-scheduler-1.1.9 bin/migrate_to_timestamps_set.rb
resque_admin-scheduler-1.1.8 bin/migrate_to_timestamps_set.rb
resque_admin-scheduler-1.1.7 bin/migrate_to_timestamps_set.rb
resque_admin-scheduler-1.0.4 bin/migrate_to_timestamps_set.rb
resque_admin-scheduler-1.3.0 bin/migrate_to_timestamps_set.rb
resque-admin-scheduler-1.3.0 bin/migrate_to_timestamps_set.rb
resque-admin-scheduler-4.3.0 bin/migrate_to_timestamps_set.rb