INNER CODE UNIT · JavaScript

reindexProducts

vuestorefront/mage2vuestorefront · src/cli.js:192

function reindexProducts(adapterName, removeNonExistent, partitions, partitionSize, initQueue, skus, updatedAfter = null, page = null) {
  removeNonExistent = _handleBoolParam(removeNonExistent)
  initQueue = _handleBoolParam(initQueue)

  let adapter = factory.getAdapter(adapterName, 'product');

  if (updatedAfter) {
    logger.info('Delta indexer started for', updatedAfter)
  }
  let tsk = new Date().getTime();

  if (partitions > 1 && adapter.isFederated()) { // standard case
    let partition_count = partitions;

    logger.info(`Running in MPM (Multi Process Mode) with partitions count = ${partition_count}`);

    adapter.getTotalCount({ updated_after: updatedAfter }).then((result) => {

View source record →