-
I'm implementing a little queue where the jobs MUST be processed one by one, so I thought to use a const worker = new Worker(
executeBulkOperationQueue.name,
async(job: Job<ExecuteBulkOperationPayload>) => { ... },
{
connection: redis,
limiter: {
max: 1,
duration: 30000, // 30 seconds
}
}
) And this works, but my worker has to wait for the remaining seconds even if the job took, for example, 3 seconds. Is it possible to start the only one worker with the new job once the old job has finished? |
Beta Was this translation helpful? Give feedback.
Answered by
nullndr
Mar 29, 2022
Replies: 1 comment 1 reply
-
Nvm, I forgot about the |
Beta Was this translation helpful? Give feedback.
1 reply
Answer selected by
nullndr
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Nvm, I forgot about the
concurrency
option and now It works better.