Merge pull request #1502 from contentstack/release/hotfix

handling concurrency

Author: cs-raj

packages/contentstack-import/src/import/modules/base-class.ts

@@ -374,7 +374,7 @@ export default abstract class BaseClass {
           .entry(apiData.entryUid)
           .publish({
             publishDetails: { environments: apiData.environments, locales: apiData.locales },
-            locale: additionalInfo.locale,
+            locale: apiData.locales[0],
           })
           .then(onSuccess)
           .catch(onReject);
@@ -395,7 +395,7 @@ export default abstract class BaseClass {
           .then(onSuccess)
           .catch(onReject);
       case 'import-taxonomy':
-        if(!apiData || !apiData.filePath){
+        if (!apiData || !apiData.filePath) {
           return Promise.resolve();
         }
         return this.stack.taxonomy(uid).import({ taxonomy: apiData.filePath }).then(onSuccess).catch(onReject);

packages/contentstack-import/src/import/modules/entries.ts

@@ -920,26 +920,24 @@ export default class EntriesImport extends BaseClass {
             apiContentDuplicate.push(c2);
           });
         });
-        for (let i = 0; i < apiContentDuplicate.length; i++) {
-          let apiContent = [apiContentDuplicate[i]];
-          await this.makeConcurrentCall({
-            apiContent,
-            processName,
-            indexerCount,
-            currentIndexer: +index,
-            apiParams: {
-              reject: onReject,
-              resolve: onSuccess,
-              entity: 'publish-entries',
-              includeParamOnCompletion: true,
-              serializeData: this.serializePublishEntries.bind(this),
-              additionalInfo: { contentType, locale: apiContentDuplicate[i]?.locale, cTUid },
-            },
-            concurrencyLimit: this.importConcurrency,
-          }).then(() => {
-            log(this.importConfig, `Published entries for content type ${cTUid} in locale ${locale}`, 'success');
-          });
-        }
+        apiContent = apiContentDuplicate;
+        await this.makeConcurrentCall({
+          apiContent,
+          processName,
+          indexerCount,
+          currentIndexer: +index,
+          apiParams: {
+            reject: onReject,
+            resolve: onSuccess,
+            entity: 'publish-entries',
+            includeParamOnCompletion: true,
+            serializeData: this.serializePublishEntries.bind(this),
+            additionalInfo: { contentType, locale, cTUid },
+          },
+          concurrencyLimit: this.importConcurrency,
+        }).then(() => {
+          log(this.importConfig, `Published entries for content type ${cTUid} in locale ${locale}`, 'success');
+        });
       }
     }
   }