INNER CODE UNIT · JavaScript

page_count

vuestorefront/mage2vuestorefront · src/cli.js:212

      let page_count = Math.ceil(total_count / page_size);

      let transaction_key = new Date().getTime();

      if (initQueue) {
        logger.info('Propagating job queue... ');

        for (let i = 1; i <= page_count; i++) {
          logger.debug(`Adding job for: ${i} / ${page_count}, page_size = ${page_size}`);
          queue.createJob('products', { page_size: page_size, page: i, updated_after: updatedAfter }).save();
        }
      } else {
        logger.info('Not propagating queue - only worker mode!');
      }

      // TODO: separate the execution part to run in multi-tenant env
      queue.process('products', partition_count, (job, done) => {
        let adapter = factory.getAdapter(adapterName, 'product');

View source record →