v3
Last updated
Was this helpful?
Last updated
Was this helpful?
rate-limit: keep priority fifo order () fixes (python) ()
worker: set redis version always in initialization () fixes ()
worker: use timeout as integer for redis lower than v6.0.0 (python) () ()
retry-job: consider priority when moving job to wait (python) () ()
rate-limit: limit by group keys has been removed in favor of a much simpler and efficent rate-limit implementation.
backoff: object mapping is replaced by single function
job: import right reference of QueueEvents () ()
job: use QueueEvents type for waitUntilFinished () ()
worker: better worker client naming ()
rate-limit: consider paused queue () ()
job: add changePriority method () ref ()
rate-limit: take in count priority () fixes ()
retry-job: get target queue list once () ()
worker: make extendLocks overridable ()
rate-limit: call pttl in script moveJobFromActiveToWait () ()
child: use named import for EventEmitter () ()
rate-limit: consider paused queue when dynamic rate limit () ()
retry: consider when queue is paused () ()
worker: add worker threads support ()
worker: close open handles after closing () fixes ()
upgrade ioredis to 5.3.2 ()
upstash: don't throw an error when detecting an upstash host ()
flow: do not remove completed children results () fixes ()
flow: consider removing dependency on removeOnFail true () ()
job: avoid error when job is moved when processing () fixes ()
worker: throw error with invalid concurrency fixes ()
worker: close lock extended timer ()
worker: correct lock extender logic ()
worker: start stalled check timer ()
worker: replace Promise.race with efficient an async fifo ()
worker: simplify lock extension to one call independent of concurrency ()
scripts: reuse keys array to avoid allocations ()
worker: improve worker memory consumption ()
worker: add remove on complete and fail options () ()
worker: run stalled check directly first time ()
worker: add a public method to run the stalled checker ()
worker: add support to disable stalled checks ()
worker: restore failed event job parameter typing () ()
worker: failed event receives an optional job parameter () fixes ()
move-to-active: remove deprecated limiter reference () ()
job: check jobKey when saving stacktrace () fixes ()
infinite worker process spawned for invalid JS file ()
worker: add a maximum block time ()
master: copy type declaration ()
redis: increase minimum default retry time ()
connection: apply console.warn in noeviction message ()
job: allow clearing job's log () ()
error: remove global prototype toJSON () fixes ()
move-to-finished: return correct delayUntil () ()
worker: fix delayed jobs with concurrency fixes ()
move-to-active: delete marker when it is moved to active () ()
move-to-active: validate next marker and return delayUntil () ()
worker: add max concurrency from the beginning () fixes ()
circular references () ()
performance issues in remove()
() ()
delayed: remove marker after being consumed () fixes ()
get-dependencies: replace slow object destructuring with single object () ()
connection: throw exception if using keyPrefix in ioredis ()
connection: use includes to check for upstash more reliably ()
job: fetch parent before job moves to complete () ()
sandbox: throw error when no exported function () fixes ()
queue: add getJobState method () ref ()
counts: delete delayed marker when needed () ()
get-children-values: replace slow object destructuring with single object () ()
exponential: respect exponential backoff delay () ()
get-jobs: filter marker () ()
worker: add ready event for blockingConnection () ()
worker: add token postfix () ()
worker: try catch setname call () fixes ()
do not allow move from active to wait if not owner of the job ()
floor pexpire to integer ()
get-workers: set name when ready event in connection () ()
job: console warn custom job ids when they represent integers () ()
queue-events: support duplicated event () ()
add-job: throw error when jobId represents an integer () ()
add-job: do not update job that already exist () ()
rate-limit: delete rateLimiterKey when 0 () ()
rate-limit: check job is active before moving to wait ()
worker: consider removed jobs in failed event () ()
flow: move parent to delayed when delay option is provided () ()
delayed: better handling of marker id ()
delayed: notify workers a delayed job is closer in time fixes ()
job: better error message in moveToFailed ()
moveToFinish: always promote delayed jobs ()
moveToFinished: revert move promoteDelayedJobs ()
repeat: allow easy migration from bullmq <3 to >=3 ()
change-delay: remove delayed stream () ()
worker: restore dynamic concurrency change () ()
workers: better error message for missing lock ()
move-to-delayed: consider promoting delayed jobs () ()
retry-job: consider promoting delayed jobs () ()
backoff: handle backoff strategy as function () ()
repeat: remove cron in favor of pattern option () ()
add support for dynamic rate limiting ()
rate-limit: remove group key support and improve global rate limit ()