bullmq example showing add job to queue with same jobId

index.ts

// only one job is added despite removeOnComplete: true
import { Queue, QueueScheduler, Job, Worker } from "bullmq"

const now = () => `[${new Date().toISOString()}]`
const queue = new Queue("Paint", {
  defaultJobOptions: {
    removeOnComplete: true,
  },
})

const worker = new Worker("Paint", async (job: Job) => {
  console.log(`${now()} worker started ${job.name}`)

  return "done"
})

worker
  .on("completed", (job: Job) => {
    console.log(`${now()} completed ${job.name}`)
  })
  .on("failed", (job: Job, failedReason: string) => {
    console.error(`${now()} worker failed`, job, failedReason)
  })
  .on("active", (job) => {
    console.log(`${now()} job active ${job.name}`, job.data)
  })
  .on("error", (e) => {
    console.error(`${now()} job error`, e)
  })
  .on("closing", () => console.log(`${now()} closing`))

const main = async (): Promise<void> => {
  console.log(`${now()} started`)

  const qs = new QueueScheduler("Paint")

  await queue.waitUntilReady()

  await queue.add("house1", { color: "red" }, { delay: 1000, jobId: "house1" })
  await queue.add("house1", { color: "blue" }, { delay: 1000, jobId: "house1" })
}

process.on("SIGINT", async () => {
  await worker.close()
  setTimeout(() => process.exit(0), 100)
})

main()