Delayed Job not working

[pateketu]

Have been using BullMq Pro for over a year now, great product BTW,

I am hoping to get some support on delayed job, I am using the latest version of BullMq Pro (7.32.2), and delayed jobs never seem to get executed

const delayedQueue = new QueuePro('DELAYED_QUEUE', {
            connection: getRedisConnection(),
        });
  await delayedQueue.add(
      'DELAYED_QUEUE',
      { token: 'someId' },
      {
          jobId: 'some_unique_id',
          removeOnComplete: true,
          removeOnFail: true,
          delay: 15 * 60 * 1000,
          group: {
              id: 'unique_group_id',
          },
      }
  );

 const worker = new WorkerPro('DELAYED_QUEUE',
                    async (job)=>{
                        console.log(job.data); //This is never called
                    }, {
                        connection: getRedisConnection(),
                    });

Hoping someone can help

[manast]

Hello. I did not want to wait 15 minutes, but the following code works as it should:

import { QueuePro, WorkerPro } from "@taskforcesh/bullmq-pro";

const connection = {
  host: "localhost",
  port: 6379,
};

const delayedQueue = new QueuePro("DELAYED_QUEUE", {
  connection,
});


await delayedQueue.add(
  "DELAYED_QUEUE",
  { token: "someId" },
  {
    jobId: "some_unique_id",
    removeOnComplete: true,
    removeOnFail: true,
    delay: 60 * 1000,
    group: {
      id: "unique_group_id",
    },
  }
);

const worker = new WorkerPro(
  "DELAYED_QUEUE",
  async (job) => {
    console.log(job.data); //This is never called
  },
  {
    connection,
  }
);

[pateketu]

May I ask what version of BullMq Pro did you use?

[manast]

7.32.2

[manast]

Interestingly this same issue was posted by a different user: #110

[pateketu]

hmm I will try out you sample code in isolation, but I am 90% sure I cannot get delayed job working in 7.32.2, I really need Group feature so can't use normal Queue, and upgraded to 7.32.2 as group limiting feature seems to work nicely, but can't get the delay working :( will report shortly