Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- tiles.each{ |args|
- CrawlWorker.perform_async(args)
- CrawlWorker.cancel!(jid)
- def cancelled?
- Sidekiq.redis {|c| c.exists("cancelled-#{jid}") }
- end
- def self.cancel!(jid)=
- Sidekiq.redis {|c| c.setex("cancelled-#{jid}", 86400, 1) }
- end
- def perform(args)
- return if cancelled?
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement