Problem Rate-Limiting a Worker

[mikebridge]

I'm not seeing my rate limits being applied with BullMQ 1.40.1. I'm following this documentation, and I think this should process one job every 10 seconds, but it seems to process them all as fast as it can:

const queue = new Queue(queueName, REDIS_CON);

const queueScheduler = new QueueScheduler(queueName, REDIS_CON);

const worker = new Worker(queueName, processJob, REDIS_CON, {
  concurrency: 1,
  limiter: { 
    max: 1,
    duration: 10000,
  },
});

[manast]

Can you extend the issue with a code snippet that reproduces the issue?

[roggervalf]

@mikebridge maybe you can use this test case https://github.com/taskforcesh/bullmq/blob/master/src/test/test_rate_limiter.ts#L62-L108 to try to reproduce your issue

[mikebridge]

Sorry, I think this is an error in the constructor arguments. REDIS_CON is

const REDIS_CON = {
  connection: {
    host: redisHost,
    port: redisPort,
  },
};

So it should be:

const worker = new Worker(queueName, processJob, {
  ...REDIS_CON,
  concurrency: 1,
  limiter: { 
    max: 1,
    duration: 10000,
  },
});