Merge pull request #2051 from gooddata/GRIF-465

GRIF-465: Allow configure number of threads using for migration dates

Author: hung-nguyen-hoang

VERSION

@@ -1 +1 @@
-3.7.95
+3.7.96

lib/gooddata/lcm/actions/migrate_gdc_date_dimension.rb

@@ -31,6 +31,9 @@ class MigrateGdcDateDimension < BaseAction
 
         description 'Sync failed list'
         param :sync_failed_list, instance_of(Type::HashType), required: false
+
+        description 'Number Of Threads'
+        param :number_of_threads_migrate_dates, instance_of(Type::StringType), required: false, default: '10'
       end
 
       RESULT_HEADER = %i[from to status]
@@ -53,6 +56,8 @@ def call(params)
         def migrate_date_dimension(params, segment_info)
           results = []
           client = params.gdc_gd_client
+          number_of_threads = Integer(params.number_of_threads_migrate_dates || '10')
+          GoodData.logger.info "Number of threads using migration dates #{number_of_threads}"
           latest_blueprint = segment_info[:from_blueprint]
           # don't migrate when latest master doesn't contain custom v2 date.
           return results unless contain_v2?(latest_blueprint)
@@ -64,7 +69,7 @@ def migrate_date_dimension(params, segment_info)
             collect_synced_status = collect_synced_status(params)
             failed_projects = ThreadSafe::Array.new
 
-            segment_info[:to].pmap do |entry|
+            segment_info[:to].pmap(number_of_threads) do |entry|
               pid = entry[:pid]
               next if sync_failed_project(pid, params)