Бычья очередь не заканчивается - PullRequest
Новая
       60

Бычья очередь не заканчивается

0 голосов
/ 22 мая 2019

Я новичок в Bull.Я попробовал запустить Bull на основании их кода документации.Процесс начинается, но моя работа еще не завершена, или я не уверен, что это событие завершено или нет?Не уверен, где я делаю ошибку

Прикрепив мой код ниже 

const Queue = require('bull');

const myFirstQueue = new Queue('my-first-queue', 
{
  redis: { 
      port: Config.redis.port, 
      host: Config.redis.host, 
      password: Config.redis.password 
  },
});



(async function ad() {
    const job = await myFirstQueue.add({
    foo: 'bar',
  });
})();

myFirstQueue.process(async (job, data) => {
  log.debug({ job, data }, 'Job data');
  let progress = 0;
  for (let i = 0; i < 10; i++) {
    await doSomething(data);
    progress += 10;
    job.progress(progress).catch(err => {
      log.debug({ err }, 'Job progress err');
    });
    log.debug({ progress }, 'After await');
  }

  return job;
});

const doSomething = data => {
  return new Promise((resolve, reject) => {
    return resolve(data);
  });
};

myFirstQueue.on('completed', (job, result) => {
  log.debug(`Job completed with result ${job}`);
});


myFirstQueue.on('progress', (job, progress) => {
log.debug(`Job progress with result ${job} ${progress}`);
});

Я вижу журналы, которые находятся внутри обработчика событий прогресса, но завершенное событие не запускается.Любая помощь приветствуется

1 Ответ

0 голосов
/ 18 июня 2019

вам нужно вызвать done () из процесса, после чего сработает только завершенное событие. 

myFirstQueue.process(async (job, done) => {
  const data = job.data;
  let progress = 0;
  for (let i = 0; i < 10; i++) {
    await doSomething(data);
    progress += 10;

    job.progress(progress).catch(err => {
      log.debug({ err }, 'Job progress err');
    });
  }

  done();
});
...