ACPT:99 Import API Parallelization

Author: aa-kashk

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

@@ -14,6 +14,7 @@
 use Magento\ImportExport\Model\Import;
 use Magento\ImportExport\Model\Import\ErrorProcessing\ProcessingError;
 use Magento\ImportExport\Model\Import\ErrorProcessing\ProcessingErrorAggregatorInterface;
+use Magento\ImportExport\Model\Import\Source\Base64EncodedCsvData;
 use Magento\ImportExport\Model\ImportFactory;
 use Magento\ImportExport\Model\ResourceModel\Helper;
 use Magento\Store\Model\ScopeInterface;
@@ -420,7 +421,7 @@ protected function _saveValidatedBunches()
         $startNewBunch = false;
 
         $source->rewind();
-        if ($this->ids) {
+        if ($source instanceof Base64EncodedCsvData) {
             $this->_dataSourceModel->cleanProcessedBunches();
         } else {
             $this->_dataSourceModel->cleanBunches();

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

@@ -13,6 +13,7 @@
 use Magento\ImportExport\Model\Import as ImportExport;
 use Magento\ImportExport\Model\Import\ErrorProcessing\ProcessingError;
 use Magento\ImportExport\Model\Import\ErrorProcessing\ProcessingErrorAggregatorInterface;
+use Magento\ImportExport\Model\Import\Source\Base64EncodedCsvData;
 
 /**
  * Import entity abstract model
@@ -394,7 +395,7 @@ protected function _saveValidatedBunches()
         $skuSet = [];
 
         $source->rewind();
-        if ($this->ids) {
+        if ($source instanceof Base64EncodedCsvData) {
             $this->_dataSourceModel->cleanProcessedBunches();
         } else {
             $this->_dataSourceModel->cleanBunches();