ACPT-99: Import API Parallelization

Author: aa-kashk

app/code/Magento/CatalogImportExport/Model/Import/Product.php

@@ -1158,6 +1158,7 @@ protected function _saveProductsData()
         if ($this->_replaceFlag) {
             $this->getOptionEntity()->clearProductsSkuToId();
         }
+        $this->getOptionEntity()->setIds($this->getIds());
         $this->getOptionEntity()->importData();
         return $this;
     }

app/code/Magento/CatalogImportExport/Model/Import/Product/Option.php

@@ -1256,7 +1256,7 @@ protected function _importData()
         $prevOptionId = 0;
         $optionId = null;
         $valueId = null;
-        while ($bunch = $this->_dataSourceModel->getNextBunch()) {
+        while ($bunch = $this->_dataSourceModel->getNextUniqueBunch($this->getIds())) {
             $products = [];
             $options = [];
             $titles = [];

app/code/Magento/ImportExport/Model/Import/AbstractEntity.php

@@ -421,9 +421,7 @@ protected function _saveValidatedBunches()
         $startNewBunch = false;
 
         $source->rewind();
-        if ($source instanceof Base64EncodedCsvData) {
-            $this->_dataSourceModel->cleanProcessedBunches();
-        } else {
+        if (!$source instanceof Base64EncodedCsvData) {
             $this->_dataSourceModel->cleanBunches();
         }
         $mainAttributeCode = $this->getMasterAttributeCode();

app/code/Magento/ImportExport/Model/Import/Entity/AbstractEntity.php

@@ -395,9 +395,7 @@ protected function _saveValidatedBunches()
         $skuSet = [];
 
         $source->rewind();
-        if ($source instanceof Base64EncodedCsvData) {
-            $this->_dataSourceModel->cleanProcessedBunches();
-        } else {
+        if (!$source instanceof Base64EncodedCsvData) {
             $this->_dataSourceModel->cleanBunches();
         }
 
@@ -911,4 +909,9 @@ public function getIds()
     {
         return $this->ids;
     }
+
+    public function setIds($ids)
+    {
+        $this->ids = $ids;
+    }
 }