Method: Resque::Failure::Redis.requeue
- Defined in:
- lib/resque/failure/redis.rb
.requeue(index) ⇒ Object
32 33 34 35 36 37 |
# File 'lib/resque/failure/redis.rb', line 32 def self.requeue(index) item = all(index) item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S") Resque.redis.lset(:failed, index, Resque.encode(item)) Job.create(item['queue'], item['payload']['class'], *item['payload']['args']) end |