@@ -132,11 +132,11 @@ protected function getIndexers(InputInterface $input)
132
132
$ dependentIndexers [] = $ this ->getDependentIndexerIds ($ indexer ->getId ());
133
133
}
134
134
135
- $ relatedIndexers = array_merge (...$ relatedIndexers );
136
- $ dependentIndexers = array_merge (...$ dependentIndexers );
135
+ $ relatedIndexers = $ relatedIndexers ? array_unique ( array_merge (...$ relatedIndexers )) : [] ;
136
+ $ dependentIndexers = $ dependentIndexers ? array_merge (...$ dependentIndexers ) : [] ;
137
137
138
138
$ invalidRelatedIndexers = [];
139
- foreach (array_unique ( $ relatedIndexers) as $ relatedIndexer ) {
139
+ foreach ($ relatedIndexers as $ relatedIndexer ) {
140
140
if ($ allIndexers [$ relatedIndexer ]->isInvalid ()) {
141
141
$ invalidRelatedIndexers [] = $ relatedIndexer ;
142
142
}
@@ -169,8 +169,9 @@ private function getRelatedIndexerIds(string $indexerId): array
169
169
$ relatedIndexerIds [] = [$ relatedIndexerId ];
170
170
$ relatedIndexerIds [] = $ this ->getRelatedIndexerIds ($ relatedIndexerId );
171
171
}
172
+ $ relatedIndexerIds = $ relatedIndexerIds ? array_unique (array_merge (...$ relatedIndexerIds )) : [];
172
173
173
- return array_unique ( array_merge (... $ relatedIndexerIds)) ;
174
+ return $ relatedIndexerIds ;
174
175
}
175
176
176
177
/**
@@ -189,8 +190,9 @@ private function getDependentIndexerIds(string $indexerId): array
189
190
$ dependentIndexerIds [] = $ this ->getDependentIndexerIds ($ id );
190
191
}
191
192
}
193
+ $ dependentIndexerIds = $ dependentIndexerIds ? array_unique (array_merge (...$ dependentIndexerIds )) : [];
192
194
193
- return array_unique ( array_merge (... $ dependentIndexerIds)) ;
195
+ return $ dependentIndexerIds ;
194
196
}
195
197
196
198
/**
@@ -251,6 +253,8 @@ private function validateSharedIndex($sharedIndex)
251
253
$ indexer = $ this ->getIndexerRegistry ()->get ($ indexerId );
252
254
/** @var \Magento\Indexer\Model\Indexer\State $state */
253
255
$ state = $ indexer ->getState ();
256
+ $ state ->setStatus (StateInterface::STATUS_WORKING );
257
+ $ state ->save ();
254
258
$ state ->setStatus (StateInterface::STATUS_VALID );
255
259
$ state ->save ();
256
260
}
0 commit comments