MC-32154: Customer grid not indexing automatically

Author: yelahin-serhiy

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

@@ -11,6 +11,8 @@
 use Magento\ImportExport\Model\Import;
 use Magento\ImportExport\Model\Import\ErrorProcessing\ProcessingErrorAggregatorInterface;
 use Magento\ImportExport\Model\Import\AbstractSource;
+use Magento\Customer\Model\Indexer\Processor;
+use Magento\Framework\App\ObjectManager;
 
 /**
  * Customer entity import
@@ -168,6 +170,11 @@ class Customer extends AbstractCustomer
         'lock_expires',
     ];
 
+    /**
+     * @var Processor
+     */
+    private $indexerProcessor;
+
     /**
      * @param \Magento\Framework\Stdlib\StringUtils $string
      * @param \Magento\Framework\App\Config\ScopeConfigInterface $scopeConfig
@@ -182,6 +189,7 @@ class Customer extends AbstractCustomer
      * @param \Magento\Customer\Model\ResourceModel\Attribute\CollectionFactory $attrCollectionFactory
      * @param \Magento\Customer\Model\CustomerFactory $customerFactory
      * @param array $data
+     * @param Processor $indexerProcessor
      * @SuppressWarnings(PHPMD.ExcessiveParameterList)
      */
     public function __construct(
@@ -197,7 +205,8 @@ public function __construct(
         \Magento\CustomerImportExport\Model\ResourceModel\Import\Customer\StorageFactory $storageFactory,
         \Magento\Customer\Model\ResourceModel\Attribute\CollectionFactory $attrCollectionFactory,
         \Magento\Customer\Model\CustomerFactory $customerFactory,
-        array $data = []
+        array $data = [],
+        ?Processor $indexerProcessor = null
     ) {
         $this->_resourceHelper = $resourceHelper;
 
@@ -254,6 +263,7 @@ public function __construct(
         /** @var $customerResource \Magento\Customer\Model\ResourceModel\Customer */
         $customerResource = $this->_customerModel->getResource();
         $this->_entityTable = $customerResource->getEntityTable();
+        $this->indexerProcessor = $indexerProcessor ?: ObjectManager::getInstance()->get(Processor::class);
     }
 
     /**
@@ -554,7 +564,7 @@ protected function _importData()
                 $this->_deleteCustomerEntities($entitiesToDelete);
             }
         }
-
+        $this->indexerProcessor->markIndexerAsInvalid();
         return true;
     }
 

app/code/Magento/CustomerImportExport/Test/Unit/Model/Import/CustomerTest.php

@@ -11,6 +11,7 @@
 use Magento\Framework\App\Filesystem\DirectoryList;
 use Magento\Framework\Exception\NoSuchEntityException;
 use Magento\ImportExport\Model\Import;
+use Magento\Framework\Indexer\StateInterface;
 
 /**
  * Test for class \Magento\CustomerImportExport\Model\Import\Customer which covers validation logic
@@ -39,6 +40,11 @@ class CustomerTest extends \PHPUnit\Framework\TestCase
      */
     protected $directoryWrite;
 
+    /**
+     * @var \Magento\Customer\Model\Indexer\Processor
+     */
+    private $indexerProcessor;
+
     /**
      * Create all necessary data for tests
      */
@@ -49,6 +55,8 @@ protected function setUp()
         $this->_model = \Magento\TestFramework\Helper\Bootstrap::getObjectManager()
             ->create(\Magento\CustomerImportExport\Model\Import\Customer::class);
         $this->_model->setParameters(['behavior' => Import::BEHAVIOR_ADD_UPDATE]);
+        $this->indexerProcessor = \Magento\TestFramework\Helper\Bootstrap::getObjectManager()
+            ->create(\Magento\Customer\Model\Indexer\Processor::class);
 
         $propertyAccessor = new \ReflectionProperty($this->_model, 'errorMessageTemplates');
         $propertyAccessor->setAccessible(true);
@@ -377,6 +385,23 @@ public function testUpdateExistingCustomers(): void
         $this->assertEquals(1, $customer->getStoreId());
     }
 
+    /**
+     * Test customer indexer gets invalidated after import when Update on Schedule mode is set
+     *
+     * @magentoDbIsolation enabled
+     * @return void
+     */
+    public function testCustomerIndexer(): void
+    {
+        $this->indexerProcessor->getIndexer()->reindexAll();
+        $statusBeforeImport = $this->indexerProcessor->getIndexer()->getStatus();
+        $this->indexerProcessor->getIndexer()->setScheduled(true);
+        $this->doImport(__DIR__ . '/_files/customers_with_gender_to_import.csv', Import::BEHAVIOR_ADD_UPDATE);
+        $statusAfterImport = $this->indexerProcessor->getIndexer()->getStatus();
+        $this->assertEquals(StateInterface::STATUS_VALID, $statusBeforeImport);
+        $this->assertEquals(StateInterface::STATUS_INVALID, $statusAfterImport);
+    }
+
     /**
      * Gets customer entity.
      *