ACP2E-2123: Issues with some pending crons that are not been executed

Author: o-iegorov

InventoryIndexer/Plugin/InventoryApi/ReindexAfterSourceItemsSavePlugin.php

@@ -9,6 +9,7 @@
 
 use Magento\InventoryApi\Api\Data\SourceItemInterface;
 use Magento\InventoryApi\Api\SourceItemsSaveInterface;
+use Magento\InventoryCatalogApi\Api\DefaultSourceProviderInterface;
 use Magento\InventoryIndexer\Indexer\SourceItem\GetSourceItemIds;
 use Magento\InventoryIndexer\Indexer\SourceItem\SourceItemIndexer;
 
@@ -27,14 +28,24 @@ class ReindexAfterSourceItemsSavePlugin
      */
     private $sourceItemIndexer;
 
+    /**
+     * @var DefaultSourceProviderInterface
+     */
+    private $defaultSourceProvider;
+
     /**
      * @param GetSourceItemIds $getSourceItemIds
      * @param SourceItemIndexer $sourceItemIndexer
+     * @param DefaultSourceProviderInterface $defaultSourceProvider
      */
-    public function __construct(GetSourceItemIds $getSourceItemIds, SourceItemIndexer $sourceItemIndexer)
-    {
+    public function __construct(
+        GetSourceItemIds $getSourceItemIds,
+        SourceItemIndexer $sourceItemIndexer,
+        DefaultSourceProviderInterface $defaultSourceProvider
+    ) {
         $this->getSourceItemIds = $getSourceItemIds;
         $this->sourceItemIndexer = $sourceItemIndexer;
+        $this->defaultSourceProvider = $defaultSourceProvider;
     }
 
     /**
@@ -49,9 +60,22 @@ public function afterExecute(
         $result,
         array $sourceItems
     ) {
+        $sourceItems = $this->sanitizeSources($sourceItems);
         $sourceItemIds = $this->getSourceItemIds->execute($sourceItems);
         if (count($sourceItemIds)) {
             $this->sourceItemIndexer->executeList($sourceItemIds);
         }
     }
+
+    private function sanitizeSources(array $sourceItems) : array
+    {
+        $result = [];
+        $defaultCode = $this->defaultSourceProvider->getCode();
+        foreach ($sourceItems as $item) {
+            if ($item->getSourceCode() !== $defaultCode) {
+                $result[] = $item;
+            }
+        }
+        return $result;
+    }
 }