finish downloading all posts after importer completes

app/importer.rb

···
     end
 
     import.update!(cursor: nil)
+    @report&.update(importer: { finished: true })
   end
 
   def process_likes(likes)

lib/tasks/import.rake

···
     puts "Elapsed time: #{(Time.now - @start).to_i} s"
 
     print " " * 80 + "\r"
-    puts "Importer: imported likes = #{@data.dig(:importer, :imported_likes) || 0} (until: #{@data.dig(:importer, :oldest_date)})"
+    puts "Importer: imported likes = #{@data.dig(:importer, :imported_likes) || 0} (until: #{@data.dig(:importer, :oldest_date)})" +
+      "#{" (DONE)" if @data.dig(:importer, :finished)}"
 
     print " " * 80 + "\r"
     puts "Downloader: imported posts = #{@data.dig(:downloader, :downloaded_posts) || 0} (until: #{@data.dig(:downloader, :oldest_date)})"
···
   downloader = PostDownloader.new
   downloader.report = report
 
-  Thread.new { downloader.import_from_queue(queue) }
+  download_thread = Thread.new { downloader.import_from_queue(queue) }
 
   trap("SIGINT") {
     puts "\n\n\n\n\n"
···
   }
 
   importer.run_import(ENV['UNTIL'])
+
+  downloader.stop_when_empty = true
+  download_thread.join
+
   puts "\n\n\n\n\n"
 end