Работа Bullmq не удалена из очереди после вызова job.remove () ⇐ Javascript

[Anonymous]

Я создаю прототип проекта с использованием Bullmq и Redis, и до сих пор все, кажется, работает нормально. Рабочие места успешно добавляются в очередь. Однако, когда я обрабатываю задания с использованием работника и вызовов job.remove () после завершения задания, задание не удаляется из очереди. с заданием, и я должен вручную запустить команду FlushDB в Redis-CLI , чтобы сбросить содержимое очереди.
Вот код I ' m Использование для прототипа: < /p>
import { Queue, Worker } from 'bullmq';
import { Redis } from 'ioredis';

const redis_connection = new Redis({
host: 'localhost',
port: 6379,
maxRetriesPerRequest: null
})

const myQueue = new Queue('my-queue',{
connection:redis_connection,
});

// Add jobs to the queue
for (let i = 0; i < 50; i++) {
myQueue.add('myJob', { foo: 'bar' , jobNumber: i });
}

const myWorker = new Worker('my-queue', async (job) => {
// Process the job data
console.log('Processing job:', job.data);
// even adding job.remove() here doesnt remove the job from the queue
}, {
connection: redis_connection,
});

myWorker.on('completed', async (job) => {
console.log(`Job with ID ${job.id} has been completed.`);
await job.remove(); // Should removes the job from the queue
});

myWorker.on('failed', async (job, err) => {
console.error(`Job with ID ${job.id} has failed with error: ${err.message}`);
await job.remove(); // Should remove the job from the queue
});


Подробнее здесь: https://stackoverflow.com/questions/793 ... job-remove