ACPT-99: Import API Parallelization

Author: aa-kashk

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

@@ -523,14 +523,7 @@ public function importSource()
         } else {
             $this->importHistoryModel->invalidateReport($this);
         }
-        try {
-            if ($this->_getEntityAdapter()->getSource() instanceof Base64EncodedCsvData) {
-                //$this->getDataSourceModel()->cleanBunchesWithId($ids);
-            }
-            // phpcs:ignore Magento2.CodeAnalysis.EmptyBlock
-        } catch (LocalizedException $e) {
-            //Do nothing if Source is not set
-        }
+
         return $result;
     }
 

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

@@ -14,7 +14,6 @@
 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;
@@ -421,9 +420,7 @@ protected function _saveValidatedBunches()
         $startNewBunch = false;
 
         $source->rewind();
-        if (!$source instanceof Base64EncodedCsvData) {
-            $this->_dataSourceModel->cleanBunches();
-        }
+        $this->_dataSourceModel->cleanProcessedBunches();
         $mainAttributeCode = $this->getMasterAttributeCode();
 
         while ($source->valid() || count($bunchRows) || isset($entityGroup)) {

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

@@ -13,7 +13,6 @@
 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
@@ -395,9 +394,7 @@ protected function _saveValidatedBunches()
         $skuSet = [];
 
         $source->rewind();
-        if (!$source instanceof Base64EncodedCsvData) {
-            $this->_dataSourceModel->cleanBunches();
-        }
+        $this->_dataSourceModel->cleanProcessedBunches();
 
         while ($source->valid() || $bunchRows) {
             if ($startNewBunch || !$source->valid()) {

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

@@ -116,21 +116,6 @@ public function cleanBunches()
         return $this->getConnection()->delete($this->getMainTable());
     }
 
-    /**
-     * Clean bunches with specific Ids
-     *
-     * @param array $ids
-     * @return void
-     */
-    public function cleanBunchesWithId(array $ids)
-    {
-        $this->getConnection()->delete(
-            $this->getMainTable(),
-            [
-                'id IN (?)' => $ids,
-            ]
-        );
-    }
 
     /**
      * Clean all bunches from table.