import { Queue, Worker, Job } from 'bullmq'; const myQueue = new Queue('firstjob', { connection: redis }); import { autorunJobs } from './processes/job.process'; async function addQueue() { await myQueue.add( 'autoclosejob', { repeat: { cron: '* * * * *' }, }, ); } addQueue(); const worker = new Worker('firstjob', async (job: Job) => { console.info('Started.'); await autorunJobs(); console.info('Closed.'); //return true; }, { connection: redis }); worker.run();

Cuando ejecuto este código, se ejecuta con éxito a la vez. Pero después espero a que el trabajador vuelva a ejecutarlo en el siguiente minuto, pero no lo hace. Lo que veo es solo una salida de console.log de una sola vez.

Los siguientes son registros de salida únicos:

 Tue, 10 May 2022 12:21:12 GMT | IDM Service | INFO | Started. dta = "some data" Tue, 10 May 2022 12:21:12 GMT | IDM Service | INFO | Closed.

Quiero esta salida después de cada minuto.

¿Que estoy haciendo mal?