Soy completamente nuevo en Bull queue y tengo una comprensión decente de JavaScript. Estoy tratando de hacer que el siguiente ejemplo funcione:
const Queue = require('bull') const myFirstQueue = new Queue('my-first-queue'); myFirstQueue.process(async (job, done) => { await doSomething(job.data); done(); }); const doSomething = data => { return new Promise((resolve, reject) => { return resolve(data); }); }; myFirstQueue.on('completed', (job, result) => { log.debug(`Job completed with result ${job}`); }); (async function ad() { const job = await myFirstQueue.add({ foo: 'bar', }); })();El error que estoy recibiendo es:
\node_modules\ioredis\built\redis\event_handler.js:177 self.flushQueue(new errors_1.MaxRetriesPerRequestError(maxRetriesPerRequest)); ^ MaxRetriesPerRequestError: Reached the max retries per request limit (which is 20). Refer to "maxRetriesPerRequest" option for details. at Socket.<anonymous> (...\node_modules\ioredis\built\redis\event_handler.js:177:37) at Object.onceWrapper (node:events:652:26) at Socket.emit (node:events:537:28) at TCP.<anonymous> (node:net:747:14) Según el error que recibo, parece que la cola no puede procesar este trabajo en absoluto y no estoy seguro de por qué recibo este error. Estoy ejecutando el script con el node fileName.js en el directorio correcto. Puedo ejecutar bien otros archivos JavaScript que son incluso más complejos que este.
EDITAR: código editado para reflejar los cambios de los comentarios, todavía tiene el mismo error.