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