How to exit after job is done ?

[emmanuelgeoffray]

Hey there,

I'm currently testing to run BullMQ with Keda.
I've setup a demo as mentioned in this conversation.
I'm trying to use keda ScaledJob option, that starts a k8s Job, a one-off tasks that run to completion and then stop.
I've tried to exit like this :

    worker.on('completed', async job => {
      console.log(`${name}#${job.id} job completed, exiting...`)
      try {
        await worker.close()
      } finally {
        process.exit(0)
      }
    })

but it randomly happens that a new bullmq job is started before exiting.
What would be the proper way to exit when the job is done and make sure that a new job is not started in the same instance ?

[manast]

Jobs are processed as long as you have a worker instance running. It seems like you are more interested in manually processing jobs, that will of course not provide concurrency as you need to manage your jobs lifecycle manually: https://docs.bullmq.io/patterns/manually-fetching-jobs