INNER CODE UNIT · JavaScript

runProductsworker

vuestorefront/mage2vuestorefront · src/cli.js:312

function runProductsworker(adapterName, partitions) {

  logger.info('Starting `productsworker` worker. Waiting for jobs ...');
  let partition_count = partitions;

  // TODO: separte the execution part to run in multi-tenant env
  queue.process('product', partition_count, (job, done) => {

    if (job && job.data.skus && Array.isArray(job.data.skus)) {

      logger.info('Starting product pull job for ' + job.data.skus.join(','));

      let adapter = factory.getAdapter(job.data.adapter ? job.data.adapter : adapterName, 'product');

      adapter.run({
        skus: job.data.skus,
        parent_sync: true,
        done_callback: () => {

View source record →