Error: cannot check if job is finished in a closing queue.

[hbakhtiyor]

Description

don't have exact steps for reproducing the error, but getting the error sometimes.

btw, why using sandbox approach is slowly?

at Timeout.<anonymous> (/demo/node_modules/bull/lib/job.js:462:19)
at ontimeout (timers.js:436:11)
at tryOnTimeout (timers.js:300:5)
at listOnTimeout (timers.js:263:5)
at Timer.processTimers (timers.js:223:10)

Minimal, Working Test code to reproduce the issue.

example.js

const Queue = require('bull');
const path = require('path');

const uuid = 1;

async function sleep(delay) {
  return new Promise((ok) => {
    setTimeout(ok, delay * 1000);
  });
}

(async () => {
  const a = 1;
  const b = 2;

  const queue = new Queue('add');
  queue.process(path.join(__dirname, 'processor.js'));

  const job = await queue.add({a, b}, {jobId: uuid, removeOnComplete: true, removeOnFail: true});

  queue.on('global:progress', async (jobId, data) => {
    if(jobId === job.id) {
      if (data === 0) {
        queue.close();
        console.log("closing");
        return;
      }

      await sleep(3);
      console.log(data);
    }
  });

  const result = await job.finished();
  console.log('finished processing', result);
})();

processor.js

async function addFunc(a, b, cb) {
  await sleep(1);
  cb(1);
  await sleep(2);
  cb(2);
  await sleep(2);
  return a + b;
}

module.exports = async function (job) {
  const result = await addFunc(
    job.data.a,
    job.data.b,
    (data) => {
      job.progress(data);
    }
  );

  job.progress(0);

  return Promise.resolve(result);
}

Bull version

v3.4.8

Additional information

node: v10.12.0
redis: 4.0.11

[stale]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. Thank you for your contributions.

[stale]

This issue has been automatically marked as stale because it has not had recent activity. It will be closed if no further activity occurs. Thank you for your contributions.