Don't forget to lycansubscribe 🐺
show queue size in report
+8
-4
+8
-4
lib/tasks/import.rake
+8
-4
lib/tasks/import.rake
···
24
24
puts "Importer: imported likes = #{@data.dig(:importer, :imported_likes) || 0} (until: #{@data.dig(:importer, :oldest_date)})"
25
25
26
26
print " " * 80 + "\r"
27
-
sum = @data.select { |k, v| k.start_with?('downloader') }.map { |k, v| v[:downloaded_posts] }.reduce(0, &:+)
28
-
oldest = @data.select { |k, v| k.start_with?('downloader') }.map { |k, v| v[:oldest_date] }.sort.first
29
-
puts "Downloader: imported posts = #{sum} (until: #{oldest})"
27
+
downloaders = @data.select { |k, v| k.start_with?('downloader') }
28
+
sum = downloaders.map { |k, v| v[:downloaded_posts] }.reduce(0, &:+)
29
+
oldest = downloaders.map { |k, v| v[:oldest_date] }.sort.first
30
+
puts "Downloaders: imported posts = #{sum} (until: #{oldest})"
30
31
31
-
print "\e[3A"
32
+
print " " * 80 + "\r"
33
+
puts "Queue size: #{@data.dig(:queue, :length) || 0}"
34
+
35
+
print "\e[4A"
32
36
end
33
37
end
34
38