ACPT-99: Import API Parallelization

Author: aa-kashk

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

@@ -126,7 +126,7 @@ public function cleanProcessedBunches()
         $this->getConnection()->delete(
             $this->getMainTable(),
             [
-                'is_processed' => true
+                'is_processed' => '1'
             ]
         );
     }
@@ -140,11 +140,10 @@ public function cleanProcessedBunches()
      */
     public function markProcessedBunches(array $ids): void
     {
-        $where = $ids ? ['id IN (?)' => $ids] : '';
         $this->getConnection()->update(
             $this->getMainTable(),
-            ['is_processed' => 1],
-            $where
+            ['is_processed' => '1'],
+            ['id IN (?)' => $ids]
         );
     }
 
@@ -286,7 +285,7 @@ public function saveBunch($entity, $behavior, array $data)
 
         $this->getConnection()->insert(
             $this->getMainTable(),
-            ['behavior' => $behavior, 'entity' => $entity, 'data' => $encodedData, 'is_processed' => 0]
+            ['behavior' => $behavior, 'entity' => $entity, 'data' => $encodedData, 'is_processed' => '0']
         );
         return $this->getConnection()->lastInsertId($this->getMainTable());
     }