ACPT-99

Author: aa-kashk

app/code/Magento/AdvancedPricingImportExport/Model/Import/AdvancedPricing.php

@@ -316,7 +316,6 @@ protected function _importData()
         } elseif (\Magento\ImportExport\Model\Import::BEHAVIOR_APPEND == $this->getBehavior()) {
             $this->saveAdvancedPricing();
         }
-        $this->_dataSourceModel->markProcessedBunches($this->getIds());
         return true;
     }
 

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

@@ -1111,7 +1111,6 @@ protected function _importData()
         } else {
             $this->_saveProductsData();
         }
-        $this->_dataSourceModel->markProcessedBunches($this->getIds());
         $this->_eventManager->dispatch('catalog_product_import_finish_before', ['adapter' => $this]);
         return true;
     }

app/code/Magento/CustomerImportExport/Model/Import/Customer.php

@@ -562,7 +562,6 @@ protected function _importData()
                 $this->_deleteCustomerEntities($entitiesToDelete);
             }
         }
-        $this->_dataSourceModel->markProcessedBunches($this->getIds());
         $this->indexerProcessor->markIndexerAsInvalid();
         return true;
     }

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

@@ -504,7 +504,8 @@ public function importSource()
         $this->addLogComment(__('Begin import of "%1" with "%2" behavior', $this->getEntity(), $this->getBehavior()));
 
         $result = $this->processImport();
-
+        $this->getDataSourceModel()->markProcessedBunches($ids);
+        $this->getDataSourceModel()->cleanProcessedBunches();
         if ($result) {
             $this->addLogComment(
                 [