Don't forget to lycansubscribe

process_posts: stop when finished

Changed files
+10 -3
app
lib
tasks
+7 -3
app/post_downloader.rb
··· 5 5 require_relative 'models/user' 6 6 7 7 class PostDownloader 8 - attr_accessor :report 8 + attr_accessor :report, :stop_when_empty 9 9 10 10 def initialize 11 11 @sky = Minisky.new(ENV['APPVIEW'] || 'public.api.bsky.app', nil) ··· 19 19 likes = queue.pop_batch 20 20 21 21 if likes.empty? 22 - sleep 1 23 - next 22 + if @stop_when_empty 23 + return 24 + else 25 + sleep 1 26 + next 27 + end 24 28 end 25 29 26 30 @report&.update(queue: { length: queue.length })
+3
lib/tasks/import.rake
··· 71 71 72 72 downloader = PostDownloader.new 73 73 downloader.report = report 74 + downloader.stop_when_empty = true 74 75 downloader.import_from_queue(queue) 76 + 77 + puts "\n\n\n\n\n" 75 78 end