Skip to content

[5.3.5](https://github.com/taskforcesh/bullmq-pro/compare/v5.3.4...v5.3.5) (2023-06-16)

Source URL: https://docs.bullmq.io/bullmq-pro/changelog/changelog-v5

  • rate-limit: keep priority fifo order (#1991) fixes #1929 (python) (56bd7ad)
  • worker: set redis version always in initialization (#1989) fixes #1988 (a1544a8)
  • worker: use timeout as integer for redis lower than v6.0.0 (python) (#1981) (0df6afa)
  • retry-job: consider priority when moving job to wait (python) (#1969) (e753855)
  • job: import right reference of QueueEvents (#1964) (689c845)
  • job: use QueueEvents type for waitUntilFinished (#1958) (881848c)
  • worker: better worker client naming (c5f63af)
  • rate-limit: take groups in count in global rate limit counter (#151) (3d8b28d)
  • remove-job: consider decreasing group concurrency (#149) (25068e2)
  • add support for job batches (1db0c94)
  • retry-job: consider promoting delayed jobs (#147) (3efd39e)
  • rate-limit: consider groups when global dynamic rate limit (#145) (6f5d1e3)
  • worker: add worker threads support (0820985)
  • upgrade ioredis to 5.3.2 (375b1be)
  • upstash: don’t throw an error when detecting an upstash host (2e06bca) ref (#143)
  • flow-producer-pro: fix opts assignment (#140) (9f8896c)
  • groups: add repair maxed group function (a1fa1d8)
  • job: avoid error when job is moved when processing (#1354) fixes #1343 #1602 (78085e4)
  • worker: throw error with invalid concurrency fixes #1723 (2a1cdbe)
  • worker: close lock extended timer (7995f18)
  • worker: correct lock extender logic (6aa3569)
  • worker: start stalled check timer (4763be0)
  • worker: run stalled check directly first time (f71ec03)
  • worker: restore failed event job parameter typing (#1707) (44c2203)
  • worker: failed event receives an optional job parameter (#1702) fixes #1690 (6009906)
  • worker: replace Promise.race with efficient an async fifo (0d94e35) ref (#138)
  • worker: simplify lock extension to one call independent of concurrency (ebf1aeb)
  • worker: add remove on complete and fail options (#1703) (cf13494)
  • worker: add a public method to run the stalled checker (3159266)
  • worker: add support to disable stalled checks (49e860c)
  • scripts: reuse keys array to avoid allocations (feac7b4)
  • worker: improve worker memory consumption (4846cf1)
  • move-to-active: remove deprecated limiter reference (#1673) (a97b22f)
  • job: check jobKey when saving stacktrace (#1681) fixes #1676 (1856c76)
  • infinite worker process spawned for invalid JS file (a445ba8)
  • worker: add a maximum block time (1a2618b)
  • master: copy type declaration (23ade6e)
  • redis: increase minimum default retry time (d521531)
  • connection: apply console.warn in noeviction message (95f171c)
  • error: remove global prototype toJSON (#1642) fixes #1414 (d4e7108)
  • rate-limit: update group concurrency after manual rate-limit (de66ec4)
  • move-to-finished: return correct delayUntil (#1643) (c4bf9fa)
  • worker: fix delayed jobs with concurrency fixes #1627 (99a8e6d)
  • move-to-active: delete marker when it is moved to active (#1634) (ad1fcea)
  • move-to-active: validate next marker and return delayUntil (#1630) (3cd3305)
  • worker: add max concurrency from the beginning (#1597) fixes #1589 (6f49db3)
  • get-dependencies: replace slow object destructuring with single object (#1612) (621748e)
  • worker: avoid calling run on base class (aba70f3)
  • counts: delete delayed marker when needed (#1583) (cc26f1c)
  • get-children-values: replace slow object destructuring with single object (#1586) (857d403)
  • worker: add ready event for blockingConnection (#1577) (992cc9e)
  • rate-limit-group: several small fixes related to manual group rate limit. (5b338d6)
  • worker: try catch setname call (#1576) fixes #1574 (0c42fd8)
  • do not allow move from active to wait if not owner of the job (dc1a307)
  • floor pexpire to integer (1d5de42)
  • get-workers: set name when ready event in connection (#1564) (de93c17)
  • job: console warn custom job ids when they represent integers (#1569) (6e677d2)
  • add-job: throw error when jobId represents an integer (#1556) (db617d7)
  • add-job: do not update job that already exist (#1550) (26f6311)
  • rate-limit: delete rateLimiterKey when 0 (#1553) (0b88e5b)
  • remove-job: check for nil as groupId instead of empty string (#119) (dd63c23)
  • add support for manually rate-limit groups (64006ee)
  • global-rate-limit: move job into group list (#116) (75384c4)
  • groups: check rate-limit when moving job to active (#117) (d247983)
  • ttl: throw error when it’s not provided as positive number (#115) (2d8ef2a)
  • Change global rate limit Move jobs to wait or groups when global rate limit