Don't forget to lycansubscribe

initialize the queue with previously unprocessed likes/posts

Changed files
+3 -3
app
lib
tasks
+2 -2
app/like_queue.rb
··· 1 1 class LikeQueue 2 2 BATCH_SIZE = 25 3 3 4 - def initialize 4 + def initialize(likes = []) 5 5 @mutex = Mutex.new 6 - @queue = [] 6 + @queue = likes 7 7 end 8 8 9 9 def push(like)
+1 -1
lib/tasks/import.rake
··· 39 39 raise "Required USER parameter missing" 40 40 end 41 41 42 - queue = LikeQueue.new 42 + queue = LikeQueue.new(Like.where(post: nil).to_a) 43 43 report = ImportReport.new 44 44 45 45 importer = Importer.new(ENV['USER'])