ACPT-99: Import API Parallelization

Author: aa-kashk

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

@@ -420,7 +420,11 @@ protected function _saveValidatedBunches()
         $startNewBunch = false;
 
         $source->rewind();
-        $this->_dataSourceModel->cleanProcessedBunches();
+        if ($this->ids) {
+            $this->_dataSourceModel->cleanProcessedBunches();
+        } else {
+            $this->_dataSourceModel->cleanBunches();
+        }
         $mainAttributeCode = $this->getMasterAttributeCode();
 
         while ($source->valid() || count($bunchRows) || isset($entityGroup)) {

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

@@ -394,7 +394,11 @@ protected function _saveValidatedBunches()
         $skuSet = [];
 
         $source->rewind();
-        $this->_dataSourceModel->cleanProcessedBunches();
+        if ($this->ids) {
+            $this->_dataSourceModel->cleanProcessedBunches();
+        } else {
+            $this->_dataSourceModel->cleanBunches();
+        }
 
         while ($source->valid() || $bunchRows) {
             if ($startNewBunch || !$source->valid()) {

app/code/Magento/ImportExport/Model/ResourceModel/Import/Data.php

@@ -116,7 +116,6 @@ public function cleanBunches()
         return $this->getConnection()->delete($this->getMainTable());
     }
 
-
     /**
      * Clean all bunches from table.
      *
@@ -141,10 +140,11 @@ public function cleanProcessedBunches()
      */
     public function markProcessedBunches(array $ids): void
     {
+        $where = $ids ? ['id IN (?)' => $ids] : '';
         $this->getConnection()->update(
             $this->getMainTable(),
             ['is_processed' => '1'],
-            ['id IN (?)' => $ids]
+            $where
         );
     }