[supply] parallel uploads for meta per language

fastlane_core/lib/fastlane_core/queue_worker.rb

@@ -6,7 +6,7 @@ module FastlaneCore
   # Use this when you have all the items that you'll process in advance.
   # Simply enqueue them to this and call `QueueWorker#start`.
   class QueueWorker
-    NUMBER_OF_THREADS = FastlaneCore::Helper.test? ? 1 : [(ENV["DELIVER_NUMBER_OF_THREADS"] || ENV.fetch("FL_NUMBER_OF_THREADS", 10)).to_i, 10].min
+    NUMBER_OF_THREADS = FastlaneCore::Helper.test? ? 1 : [ENV["DELIVER_NUMBER_OF_THREADS"], ENV["FL_NUMBER_OF_THREADS"], 10].map(&:to_i).find(&:positive?).clamp(1, ENV.fetch("FL_MAX_NUMBER_OF_THREADS", 10).to_i)
 
     # @param concurrency (Numeric) - A number of threads to be created
     # @param block (Proc) - A task you want to execute with enqueued items

supply/lib/supply/uploader.rb

@@ -1,6 +1,10 @@
+require 'fastlane_core'
+
 module Supply
   # rubocop:disable Metrics/ClassLength
   class Uploader
+    UploadJob = Struct.new(:language, :version_code)
+
     def perform_upload
       FastlaneCore::PrintTable.print_values(config: Supply.config, hide_keys: [:issuer], mask_keys: [:json_key_data], title: "Summary for supply #{Fastlane::VERSION}")
 
@@ -81,25 +85,32 @@ def perform_upload_meta(version_codes, track_name)
           version_codes.to_s == ""
         end
 
+        release_notes = []
+        upload_worker = FastlaneCore::QueueWorker.new do |job|
+          UI.message("Preparing uploads for language '#{job.language}'...")
+          start_time = Time.now
+          listing = client.listing_for_language(job.language)
+          upload_metadata(job.language, listing) unless Supply.config[:skip_upload_metadata]
+          upload_images(job.language) unless Supply.config[:skip_upload_images]
+          upload_screenshots(job.language) unless Supply.config[:skip_upload_screenshots]
+          release_notes << upload_changelog(job.language, job.version_code) unless Supply.config[:skip_upload_changelogs]
+          UI.message("Uploaded all items for language '#{job.language}'... (#{Time.now - start_time} secs)")
+        rescue => error
+          UI.abort_with_message!("#{job.language} - #{error}")
+        end
+
         version_codes.each do |version_code|
           UI.user_error!("Could not find folder #{metadata_path}") unless File.directory?(metadata_path)
 
           track, release = fetch_track_and_release!(track_name, version_code)
           UI.user_error!("Unable to find the requested track - '#{Supply.config[:track]}'") unless track
           UI.user_error!("Could not find release for version code '#{version_code}' to update changelog") unless release
 
-          release_notes = []
-          all_languages.each do |language|
-            next if language.start_with?('.') # e.g. . or .. or hidden folders
-            UI.message("Preparing to upload for language '#{language}'...")
-
-            listing = client.listing_for_language(language)
-
-            upload_metadata(language, listing) unless Supply.config[:skip_upload_metadata]
-            upload_images(language) unless Supply.config[:skip_upload_images]
-            upload_screenshots(language) unless Supply.config[:skip_upload_screenshots]
-            release_notes << upload_changelog(language, version_code) unless Supply.config[:skip_upload_changelogs]
-          end
+          upload_worker.batch_enqueue(
+            # skip . or .. or hidden folders
+            all_languages.reject { |lang| lang.start_with?('.') }.map { |lang| UploadJob.new(lang, version_code) }
+          )
+          upload_worker.start
 
           upload_changelogs(release_notes, release, track, track_name) unless release_notes.empty?
         end