ACPT-99: Import API Parallelization

Author: aa-kashk

app/code/Magento/CatalogImportExport/Test/Unit/Model/Import/Product/Type/OptionTest.php

@@ -409,12 +409,12 @@ protected function _getSourceDataMocks(bool $addExpectations, bool $doubleOption
     {
         $csvData = $this->_loadCsvFile();
 
-        $dataSourceModel = $this->getMockBuilder(\stdClass::class)->addMethods(['getNextBunch'])
+        $dataSourceModel = $this->getMockBuilder(\stdClass::class)->addMethods(['getNextUniqueBunch'])
             ->disableOriginalConstructor()
             ->getMock();
         if ($addExpectations) {
             $dataSourceModel
-                ->method('getNextBunch')
+                ->method('getNextUniqueBunch')
                 ->willReturnOnConsecutiveCalls($csvData['data'], null);
         }
 
@@ -1039,11 +1039,11 @@ public function validateAmbiguousDataDataProvider(): array
      */
     public function testParseRequiredData(): void
     {
-        $modelData = $this->getMockBuilder(\stdClass::class)->addMethods(['getNextBunch'])
+        $modelData = $this->getMockBuilder(\stdClass::class)->addMethods(['getNextUniqueBunch'])
             ->disableOriginalConstructor()
             ->getMock();
         $modelData
-            ->method('getNextBunch')
+            ->method('getNextUniqueBunch')
             ->willReturnOnConsecutiveCalls(
                 [
                     [

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

@@ -910,6 +910,12 @@ public function getIds()
         return $this->ids;
     }
 
+    /**
+     * Set Ids of Validated Rows
+     *
+     * @param $ids
+     * @return void
+     */
     public function setIds($ids)
     {
         $this->ids = $ids;

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

@@ -229,7 +229,7 @@ public function getNextBunch()
         $dataRow = null;
         if ($this->_iterator->valid()) {
             $encodedData = $this->_iterator->current();
-            if (array_key_exists(0, $encodedData) && $encodedData[0]) {
+            if (!empty($encodedData[0])) {
                 $dataRow = $this->jsonHelper->jsonDecode($encodedData[0]);
                 $this->_iterator->next();
             }