Permalink
Browse files

Sidekiq 0.11.2 compatibility

  • Loading branch information...
1 parent af1e7eb commit 5efdaaef73c413849eb22ca979e410c4aeabd608 @captainbeardo captainbeardo committed Apr 9, 2012
Showing with 2 additions and 1 deletion.
  1. +2 −1 lib/sidekiq-scheduler/manager.rb
@@ -49,7 +49,8 @@ def find_scheduled_work(timestamp)
break logger.debug("Finished processing queue for timestamp #{timestamp}") unless msg = redis { |r| r.lpop("delayed:#{timestamp}") }
item = MultiJson.decode(msg)
queue = item.delete('queue')
- Sidekiq::Client.push(queue, item)
+ item['class'] = constantize(item['class']) # Sidekiq expects the class to be constantized.
+ Sidekiq::Client.push(item)
end
Sidekiq::Client.remove_scheduler_queue(timestamp)
end

0 comments on commit 5efdaae

Please sign in to comment.