Changelog

7.30.4 (2025-03-01)

Bug Fixes

  • job-scheduler: consider removing current job from wait, paused or prioritized (#3066) (97cd2b1)

Performance Improvements

  • delayed: add marker once when promoting delayed jobs (#3096) (python) (38912fb)

7.30.3 (2025-02-21)

Bug Fixes

  • repeat: use JobPro class when creating delayed job (#292) (ce9eff8)

  • worker: do not execute run method when no processor is defined when resuming (#3089) (4a66933)

  • worker: do not resume when closing (#3080) (024ee0f)

  • job: set processedBy when moving job to active in moveToFinished (#3077) fixes #3073 (1aa970c)

  • drain: pass delayed key for redis cluster (#3074) (05ea32b)

  • job-scheduler: restore limit option to be saved (#3071) (3e649f7)

  • job-scheduler: return undefined in getJobScheduler when it does not exist (#3065) fixes #3062 (548cc1c)

  • fix return type of getNextJob (b970281)

Features

  • job: add moveToWait method for manual processing (#2978) (5a97491)

  • queue: support removeGlobalConcurrency method (#3076) (ece8532)

Performance Improvements

  • add-job: add job into wait or prioritized state when delay is provided as 0 (#3052) (3e990eb)

7.30.2 (2025-02-20)

Bug Fixes

  • worker: wait fetched jobs to be processed when closing (#3059) (d4de2f5)

7.30.1 (2025-02-20)

Bug Fixes

  • job: save processedBy attribute when preparing for processing (#300) (c947f6e)

7.30.0 (2025-02-19)

Features

7.29.0 (2025-02-18)

Features

  • job-scheduler: revert add delayed job and update in the same script (9f0f1ba)

7.28.0 (2025-02-15)

Bug Fixes

  • worker: evaluate if a job needs to be fetched when moving to failed (#3043) (406e21c)

  • retry-job: consider updating failures in job (#3036) (21e8495)

  • flow-producer: add support for skipWaitingForReady (6d829fc)

Features

  • job-scheduler: save limit option (#3033) (a1571ea)

  • queue: add option to skip wait until connection ready (e728299)

7.27.0 (2025-02-12)

Bug Fixes

  • worker: avoid possible hazard in closing worker (0f07467)

Features

  • queue-getters: add prometheus exporter (078ae9d)

  • job-scheduler: save iteration count (#3018) (ad5c07c)

  • sandbox: add support for getChildrenValues (dcc3b06)

7.26.6 (2025-02-03)

Bug Fixes

  • worker: add missing otel trace when extending locks (#290) (efbf948)

7.26.5 (2025-02-02)

Bug Fixes

  • worker: remove the use of multi in extend locks (3862075)

7.26.4 (2025-01-30)

Bug Fixes

  • retry-job: pass stalled key instead of limiter (#291) (e981c69)

7.26.3 (2025-01-26)

Bug Fixes

  • queue: use same telemetry logic in add method as BullMQ (#287) (214c0d9)

7.26.2 (2025-01-18)

Bug Fixes

  • job-scheduler: use delayed job data when template data is not present (#3010) fixes #3009 (95edb40)

  • job-scheduler: add next delayed job only when prevMillis matches with producerId (#3001) (4ea35dd)

  • job-scheduler: avoid duplicates when upserting in a quick sequence (#2991) (e8cdb99)

  • dynamic-rate-limit: validate job lock cases (#2975) (8bb27ea)

Performance Improvements

  • job-scheduler: add delayed job and update scheduler in same script (#2997) (9be28a0)

  • job-scheduler: add delayed job and scheduler in same script (#2993) (95718e8)

7.26.1 (2024-12-22)

Bug Fixes

  • sandbox: fix issue where job could stay in active forever (#2979) (c0a6bcd)

  • sandboxed: fix detecting special errors by sending default messages (#2967) fixes #2962 (52b0e34)

7.26.0 (2024-12-17)

Bug Fixes

  • scripts: make sure jobs fields are not empty before unpack (4360572)

  • guarantee every repeatable jobs are slotted (9917df1)

  • job-scheduler: avoid duplicated delayed jobs when repeatable jobs are retried (af75315)

  • job-scheduler: omit deduplication and debounce options from template options (#2960) (b5fa6a3)

Features

  • telemetry: add option to omit context propagation on jobs (#2946) (6514c33)

  • replace multi by lua scripts in moveToFailed (#2958) (c19c914)

7.25.0 (2024-12-17)

Features

  • queue: enhance getJobSchedulers method to include template information (#2956) ref #2875 (5b005cd)

7.24.0 (2024-12-07)

Bug Fixes

  • worker: catch connection error when moveToActive is called (#2952) (544fc7c)

  • scheduler-template: remove console.log when getting template information (#2950) (3402bfe)

  • flow: allow using removeOnFail and failParentOnFailure in parents (#2947) fixes #2229 (85f6f6f)

  • job-scheduler: upsert template when same pattern options are provided (#2943) ref #2940 (b56c3b4)

Features

  • queue: enhance getJobScheduler method to include template information (#2929) ref #2875 (cb99080)

  • queue: add getJobSchedulersCount method (#2945) (38820dc)

7.23.1 (2024-12-06)

Bug Fixes

  • stalled: move parent to group when needed (#276) (8449a41)

7.23.0 (2024-11-26)

Bug Fixes

  • scheduler: remove deprecation warning on immediately option (#2923) (14ca7f4)

Features

  • telemetry: add telemetry support (#273) (e5cc134)

  • queue: refactor a protected addJob method allowing telemetry extensions (09f2571)

7.22.0 (2024-11-22)

Bug Fixes

  • queue: change _jobScheduler from private to protected for extension (#2920) (34c2348)

  • scheduler: use Job class from getter for extension (#2917) (5fbb075)

  • telemetry: do not set span on parent context if undefined (c417a23)

Features

  • job-scheduler: add telemetry support to the job scheduler (72ea950)

  • queue: add rateLimit method (#2896) (db84ad5)

  • queue: add removeRateLimitKey method (#2806) (ff70613)

Performance Improvements

  • marker: add base markers while consuming jobs to get workers busy (#2904) fixes #2842 (1759c8b)

7.21.1 (2024-11-15)

Bug Fixes

  • deps: use fixed version of bullmq v5.26.1 (#269) (33e73e4)

7.21.0 (2024-11-14)

Bug Fixes

  • queue: fix generics to be able to properly be extended (f2495e5)

Features

  • queue-pro: expose jobs pro in getters (e1da097)

  • improve queue getters to use generic job type (#2905) (c9531ec)

7.20.2 (2024-11-13)

Bug Fixes

  • job-scheculer: avoid hazards when upserting job schedulers concurrently (022f7b7)

  • connection: do not allow to set blockingConnection option (#2851) (9391cc2)

7.20.1 (2024-11-10)

Bug Fixes

  • repeatable: only apply immediately in the first iteration (f69cfbc)

7.20.0 (2024-11-09)

Bug Fixes

  • scripts: set package version by default for extension (#2887) (b955340)

  • worker: allow retrieving concurrency value (#2883) fixes #2880 (52f6317)

  • connection: set packageVersion as protected attribute for extension (#2884) (411ccae)

Features

  • queue-events: add QueueEventsProducer for publishing custom events (#2844) (5eb03cd)

  • flows: add telemetry support (#2879) (5ed154b)

7.19.0 (2024-11-08)

Bug Fixes

  • deps: bump msgpackr to 1.1.2 to resolve ERR_BUFFER_OUT_OF_BOUNDS error (#2882) ref #2747 (4d2136c)

Features

7.18.0 (2024-11-07)

Bug Fixes

  • proper way to get version (b4e25c1)

  • scripts: add missing wait in isJobInList (9ef865c)

  • redis: use version for naming loaded lua scripts (fe73f6d)

Features

  • queue: add option to skip metas update (b7dd925)

  • queue: add queue version support (#2822) (3a4781b)

7.17.2 (2024-10-23)

Bug Fixes

  • sandbox: fix serialization of error with circular references are present (#2815) fix #2813 (a384d92)

7.17.1 (2024-10-18)

Bug Fixes

  • worker-pro: use JobPro as part of WorkerProListener events (#260) (966ac9c)

7.17.0 (2024-10-12)

Bug Fixes

  • repeat: also consider startDate when using "every" (25bbaa8)

  • sandbox: catch exit errors (#2800) (6babb9e)

Features

  • repeat: deprecate immediately on job scheduler (ed047f7)

  • job: expose priority value (#2804) (9abec3d)

  • job: add deduplication logic (#2796) (0a4982d)

  • queue: add new upsertJobScheduler, getJobSchedulers and removeJobSchedulers methods (dd6b6b2)

  • worker-fork: allow passing fork options (#2795) (f7a4292)

  • worker-thread: allow passing Worker options (#2791) ref #1555 (6a1f7a9)

7.16.0 (2024-09-24)

Bug Fixes

  • repeatable: avoid delayed job deletion if next job already existed (#2778) (6a851c1)

  • connection: allow passing connection string into IORedis (#2746) (73005e8)

  • metrics: differentiate points in different minutes to be more accurate (#2766) (python) (7cb670e)

  • pattern: do not save offset when immediately is provided (#2756) (a8cb8a2)

Features

  • groups: support changing priority intra groups (#255) (2b0bf7e)

  • queue: add getDebounceJobId method (#2717) (a68ead9)

Performance Improvements

  • metrics: save zeros as much as max data points (#2758) (3473054)

7.15.4 (2024-09-21)

Bug Fixes

  • repeat: replace delayed job when updating repeat key (88029bb)

7.15.3 (2024-09-07)

Bug Fixes

7.15.2 (2024-09-07)

Bug Fixes

  • flow: remove debounce key when parent is moved to fail (#2720) (d51aabe)

  • flow: recursive ignoreDependencyOnFailure option (#2712) (53bc9eb)

  • job: throw error if removeDependencyOnFailure and ignoreDependencyOnFailure are used together (#2711) (967632c)

  • job: change moveToFinished return type to reflect jobData (#2706) ref #2342 (de094a3)

  • stalled: support removeDependencyOnFailure option when job is stalled (#2708) (e0d3790)

Performance Improvements

  • fifo-queue: use linked list structure for queue (#2629) (df74578)

7.15.1 (2024-09-06)

Bug Fixes

  • worker: fix close sequence to reduce risk for open handlers (#2656) (8468e44)

  • flow: validate parentData before ignoreDependencyOnFailure when stalled check happens (#2702) (python) (9416501)

7.15.0 (2024-09-05)

Bug Fixes

Features

  • queue-pro: add getGroupRateLimitTtl method (#250) (5a907d9)

Performance Improvements

7.14.1 (2024-08-09)

Bug Fixes

  • flow: get groupId from moveToWaitingChildren script (#247) (1bee26e)

7.14.0 (2024-08-08)

Features

  • queue-events: pass debounceId as a param of debounced event (#2678) (97fb97a)

  • job: allow passing debounce as option (#2666) (163ccea)

7.13.0 (2024-07-31)

Bug Fixes

  • repeatable: remove repeat hash when removing repeatable job (#2676) (97a297d)

  • repeatable: keep legacy repeatables if it exists instead of creating one with new structure (#2665) (93fad41)

  • repeatable: consider removing legacy repeatable job (#2658) fixes #2661 (a6764ae)

  • repeatable: pass custom key as an args in addRepeatableJob to prevent CROSSSLOT issue (#2662) fixes #2660 (9d8f874)

Features

Performance Improvements

7.12.0 (2024-07-26)

Features

7.11.0 (2024-07-14)

Features

7.10.1 (2024-07-09)

Bug Fixes

  • get-groups-count: consider other group states apart of waiting (#240) (eccd4e6)

7.10.0 (2024-07-06)

Bug Fixes

  • queue-getters: consider passing maxJobs when calling getRateLimitTtl (#2631) fixes #2628 (9f6609a)

  • job: consider changing priority to 0 (#2599) (4dba122)

  • priority: consider paused state when calling getCountsPerPriority (python) (#2609) (6e99250)

  • priority: use module instead of bit.band to keep order (python) (#2597) (9ece15b)

Features

Performance Improvements

7.9.2 (2024-06-28)

Bug Fixes

  • groups: promote maxed groups after decreasing active count (#234) (545b6c2)

7.9.1 (2024-06-18)

Bug Fixes

  • maxed: consider passing max concurrency into repairMaxedGroup (#232) (a3885a5)

7.9.0 (2024-06-15)

Features

  • groups: allow passing limit when calling getGroupsJobsCount (#230) (ac0469f)

7.8.3 (2024-06-13)

Bug Fixes

  • groups: consider removing job from prioritized group when using remove method (#229) (b61b96f)

7.8.2 (2024-05-31)

Bug Fixes

  • worker: properly cancel blocking command during disconnections (2cf12b3)

  • extendlock,createbulk use pipeline no multi command (a053d9b)

  • repeat: throw error when endDate is pointing to the past (#2574) (5bd7990)

  • retry-job: throw error when job is not in active state (#2576) (ca207f5)

  • sandboxed: ensure DelayedError is checked in Sandboxed processors (#2567) fixes #2566 (8158fa1)

  • job: validate job existence when adding a log (#2562) (f87e3fe)

7.8.1 (2024-05-18)

Bug Fixes

  • groups: remove concurrency when removing group (#226) (332728e)

7.8.0 (2024-05-10)

Features

7.7.2 (2024-05-04)

Bug Fixes

  • worker: make sure clearTimeout is always called after bzpopmin (782382e)

  • worker: force timeout on bzpopmin command (#2543) (ae7cb6c)

Performance Improvements

  • worker: do not call bzpopmin when blockDelay is lower or equal 0 (#2544) ref #2466 (9760b85)

7.7.1 (2024-04-30)

Bug Fixes

  • worker-pro: correct typo in options argument for limiter (0e999dd)

7.7.0 (2024-04-30)

Features

  • groups: support for local group concurrency using setGroupConcurrency method (#220) (159a341)

7.6.2 (2024-04-25)

Bug Fixes

  • stalled: consider ignoreDependencyOnFailure option (python) (#2540) fixes #2531 (0140959)

7.6.1 (2024-04-23)

Bug Fixes

  • worker: return minimumBlockTimeout depending on redis version (python) (#2532) (83dfb63)

  • stalled: consider failParentOnFailure when moving child into failed (#2526) fixes #2464 (python) (5e31eb0)

Performance Improvements

  • worker: reset delays after generating blockTimeout value (#2529) (e92cea4)

7.6.0 (2024-04-17)

Features

7.5.0 (2024-04-10)

Bug Fixes

  • worker: use 0.002 as minimum timeout for redis version lower than 7.0.8 (#2515) fixes #2466 (44f7d21)

Features

  • allow arbitrary large drainDelay (9693321)

Performance Improvements

  • stalled: remove jobId from stalled after removing lock when moved from active (#2512) (python) (64feec9)

  • add-to-group: skip reinsertion of group (#215) (6823251)

7.4.1 (2024-04-07)

Bug Fixes

7.4.0 (2024-04-04)

Bug Fixes

  • connection: ignore error when setting custom end status (#2473) (3e17e45)

  • job: stack trace limit (#2487) (cce3bc3)

  • scripts: use command name in error message when moving to finished (#2483) (3c335d4)

  • queue: use QueueOptions type in opts attribute (#2481) (51a589f)

  • worker: validate drainDelay must be greater than 0 (#2477) (ab43693)

Features

  • getters: add getWorkersCount (743c7aa)

7.3.1 (2024-03-30)

Bug Fixes

  • group-limit: set rate limiting even when group is empty (#212) (08824cf)

7.3.0 (2024-03-16)

Bug Fixes

  • deps: move fast-glob and minimatch as dev-dependencies (#2452) (cf13b31)

  • worker: set blockTimeout as 0.001 when reach the time to get delayed jobs (#2455) fixes #2450 (2de15ca)

Features

7.2.0 (2024-03-15)

Bug Fixes

  • deps: replaced glob by fast-glob due to security advisory (91cf9a9)

  • sandbox: extend SandboxedJob from JobJsonSandbox (#2446) fixes #2439 (7606e36)

  • add-job: fix parent job cannot be replaced error message (#2441) (1e9a13f)

Features

  • worker: add support for naming workers (7ba2729)

7.1.0 (2024-03-14)

Bug Fixes

  • flow: remove failed children references on auto removal (#2432) (8a85207)

  • redis-connection: close redis connection even when initializing (#2425) fixes #2385 (1bc26a6)

Features

  • flow: add ignoreDependencyOnFailure option (#2426) (c7559f4)

7.0.0 (2024-03-12)

Bug Fixes

  • worker: update processor types (#193) (8ebb72e)

  • flow: parent job cannot be replaced (python) (#2417) (2696ef8)

  • reprocess-job: add marker if needed (#2406) (5923ed8)

  • rate-limit: move job to wait even if ttl is 0 (#2403) (c1c2ccc)

  • stalled: consider adding marker when moving job back to wait (#2384) (4914df8)

  • retry-jobs: add marker when needed (#2374) (1813d5f)

  • security: upgrade msgpackr https://github.com/advisories/GHSA-7hpj-7hhx-2fgx (7ae0953)

  • worker: worker can be closed if Redis is down (#2350) (888dcc2)

  • worker: throw error if connection is missing (6491a18)

Features

Performance Improvements

  • marker: differentiate standard and delayed markers (python) (#2389) (18ebee8)

  • change-delay: add delay marker when needed (#2411) (8b62d28)

  • flow: add marker when moving parent to wait (python) (#2408) (6fb6896)

  • move-to-active: check rate limited once (#2391) (ca6c17a)

BREAKING CHANGES

6.11.0 (2024-02-26)

Features

  • expose sandboxed-job-pro interface (6652e0a)

6.10.0 (2024-02-21)

Features

  • groups: add sandbox support for groups (53be7a0)

6.9.6 (2024-01-31)

Bug Fixes

  • groups: remove group when removing last job (#199) (3066686)

6.9.5 (2024-01-27)

Bug Fixes

  • batches: differentiate movetoBatchFinished responses (#198) (bb74c50)

6.9.4 (2024-01-20)

Bug Fixes

  • backoff: set marker after adding delayed job (#197) (50a012e)

6.9.3 (2024-01-18)

Performance Improvements

  • prioritized: get target list once in addPrioritizedJob (#195) (51cf4a3)

6.9.2 (2024-01-17)

Bug Fixes

  • groups: consider prioritized groups when maxSize is provided (#194) (1c345c5)

6.9.1 (2024-01-15)

Bug Fixes

  • events: emit drained event only when finishing jobs (#192) (22a503d)

6.9.0 (2023-12-28)

Bug Fixes

  • flows: update constructor and methods to match queue base (#2324) (d6c2064)

  • sandboxed: better compatibility with esbuild (8eaf955)

  • child-processor: preserve dynamic imports in commonjs (d97a5e0)

  • flows: add meta key to queues created with flows (272ec69)

  • repeat-strategy: add missing Promise return type (#2301) (6f8f534)

  • update-progress: remove old updateProgress script to prevent conflict (#2298) (python) (e65b819)

  • worker: get dirname by using module.filename (#2296) fixes #2288 (6e4db5a)

  • worker: should cap update progress events (2cab9e9)

Features

  • sandbox: support URL (local files) as processor file (7eea670)

  • queue: add a paginated getDependencies (#2327) (c5b8ba3)

  • sandboxes: use the more compatible dynamic import instead of require (6d2fe6e)

6.8.0 (2023-11-30)

Bug Fixes

  • worker: do not wait for slow jobs fixes #2290 (568d758)

  • utils: use EventEmitter as a type instead of a namespace (#2283) (41c9d1d)

  • job: set delay value on current job instance when it is retried (#2266) (python) (76e075f)

Features

  • worker: better handling of concurrency when fetching jobs (#2242) (d2e2035)

Performance Improvements

  • rate-limit: continue promoting groups when there are in paused state (#187) (17f9e81)

6.7.0 (2023-11-22)

Features

Bug Fixes

  • utils: use EventEmitter as a type instead of a namespace (#2283) (41c9d1d)

  • job: set delay value on current job instance when it is retried (#2266) (python) (76e075f)

  • connection: better handling of attached listeners (02474ad)

  • connection: move redis instance check to queue base (13a339a)

  • update delay job property when moving to delayed set (#2261) (69ece08)

  • add-job: trim events when waiting-children event is published (#2262) (python) (198bf05)

6.6.2 (2023-11-03)

Bug Fixes

  • worker: keep extending locks while closing workers (#2259) (c4d12ea)

  • sandbox: do not return empty object result when it is undefined (#2247) (308db7f)

  • events: do not publish removed event on non-existent jobs (#2227) (c134606)

Performance Improvements

  • redis-connection: check redis version greater or equal than v6 only once (#2252) (a09b15a)

  • events: trim events when removing jobs (#2235) (python) (889815c)

6.6.1 (2023-10-11)

Bug Fixes

6.6.0 (2023-10-06)

Bug Fixes

  • delayed: trim events when moving jobs to delayed (python) (#2211) (eca8c2d)

Features

  • queue: expose addJobLog and updateJobProgress (#2202) (2056939)

6.5.0 (2023-09-28)

Features

  • sandbox: convert wrapJob method as protected for extension (#2182) (1494b55)

Bug Fixes

  • queue: batched unpack now uses range (#2188) (b5e97f4)

  • worker: forward skipVersionCheck to blockingConnection (#2189) ref #2149 (c8aa9a3)

  • worker: throw exception with NaN as concurrency (#2184) (f36ac8b)

  • queue: differentiate score purpose per state in clean method (#2133) fixes #2124 (862f10b)

6.4.0 (2023-09-16)

Features

Bug Fixes

  • remove: change error message when job is locked (python) (#2175) (2f5628f)

  • sandbox: ignore extra params on processor (#2142) (3602c20)

6.3.4 (2023-08-18)

Bug Fixes

  • worker: abort rate-limit delay when closing worker (#179) (4ad650b)

6.3.3 (2023-08-15)

Bug Fixes

  • queue: throw error when name is not provided (#178) (9715bf1)

6.3.2 (2023-08-11)

Bug Fixes

  • correct group rate limit in some edge cases (#177) (c3c87a7)

6.3.1 (2023-08-10)

Performance Improvements

6.3.0 (2023-08-03)

Features

6.2.4 (2023-07-29)

Bug Fixes

6.2.3 (2023-07-27)

Performance Improvements

  • groups: do not move job to paused when promoting rate-limited group (#169) (fa2bb3c)

6.2.2 (2023-07-26)

Features

  • queue: add promoteJobs to promote all delayed jobs (6074592)

  • job: add option for removing children in remove method (python) (#2064) (841dc87)

  • job: add removeDependencyOnFailure option (#1953) (ffd49e2)

6.2.1 (2023-07-25)

Bug Fixes

  • flow: emit delayed event when parent is moved to delayed (#166) (38afe1c)

6.2.0 (2023-07-25)

Features

6.1.1 (2023-07-18)

Bug Fixes

6.1.0 (2023-07-18)

Bug Fixes

  • fix the GroupMaxSizeExceededError prototype (a1b6a96)

Features

6.0.5 (2023-07-11)

Bug Fixes

  • pause-group: do not move job to wait when queue is paused (#162) (458b381)

6.0.4 (2023-07-07)

Bug Fixes

  • group: move job into group list when paused and dynamic rate limit (#161) (1625f36)

6.0.3 (2023-07-05)

Bug Fixes

  • rate-limit: emit waiting event in rateLimitGroup (#160) (eaf3cd7)

6.0.2 (2023-07-04)

Performance Improvements

  • remove-job: do not remove last group id (#159) (f5a3cd5)

6.0.1 (2023-06-29)

Bug Fixes

  • job: save groupId even when the job is a parent (#157) (1debbf4)

6.0.0 (2023-06-26)

Performance Improvements

  • priority: add prioritized as a new state (#155) (b2391ca)

BREAKING CHANGES

  • priority: priority is separated in its own zset, no duplication needed

  • change job method name update to updateData

ref faster priority jobs

5.3.5 (2023-06-16)

Bug Fixes

  • 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)

5.3.4 (2023-06-06)

Features

Bug Fixes

5.3.3 (2023-05-30)

Bug Fixes

  • rate-limit: take groups in count in global rate limit counter (#151) (3d8b28d)

5.3.2 (2023-05-24)

Bug Fixes

5.3.1 (2023-05-23)

Bug Fixes

  • remove-job: consider decreasing group concurrency (#149) (25068e2)

5.3.0 (2023-05-23)

Features

  • add support for job batches (1db0c94)

5.2.5 (2023-05-20)

Bug Fixes

  • retry-job: consider promoting delayed jobs (#147) (3efd39e)

5.2.4 (2023-05-16)

Bug Fixes

  • rate-limit: consider groups when global dynamic rate limit (#145) (6f5d1e3)

5.2.3 (2023-05-09)

Features

  • worker: add worker threads support (0820985)

  • upgrade ioredis to 5.3.2 (375b1be)

Bug Fixes

5.2.2 (2023-04-18)

Features

  • upstash: don't throw an error when detecting an upstash host (2e06bca) ref (#143)

5.2.1 (2023-04-15)

Bug Fixes

  • flow-producer-pro: fix opts assignment (#140) (9f8896c)

5.2.0 (2023-03-23)

Features

  • groups: add repair maxed group function (a1fa1d8)

5.1.15 (2023-03-23)

Bug Fixes

  • 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)

Features

  • 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)

Performance Improvements

  • scripts: reuse keys array to avoid allocations (feac7b4)

  • worker: improve worker memory consumption (4846cf1)

  • move-to-active: remove deprecated limiter reference (#1673) (a97b22f)

5.1.14 (2023-02-15)

Bug Fixes

  • 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)

5.1.13 (2023-02-07)

Bug Fixes

  • 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)

Features

5.1.12 (2023-01-26)

Bug Fixes

  • 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)

5.1.11 (2023-01-10)

Bug Fixes

Performance Improvements

  • get-dependencies: replace slow object destructuring with single object (#1612) (621748e)

5.1.10 (2022-12-29)

Bug Fixes

Features

5.1.9 (2022-12-23)

Bug Fixes

5.1.8 (2022-12-22)

Bug Fixes

  • worker: avoid calling run on base class (aba70f3)

5.1.7 (2022-12-16)

Performance Improvements

  • counts: delete delayed marker when needed (#1583) (cc26f1c)

  • get-children-values: replace slow object destructuring with single object (#1586) (857d403)

5.1.6 (2022-12-15)

Bug Fixes

5.1.5 (2022-12-13)

Bug Fixes

Features

  • worker: add ready event for blockingConnection (#1577) (992cc9e)

5.1.4 (2022-12-08)

Bug Fixes

  • rate-limit-group: several small fixes related to manual group rate limit. (5b338d6)

5.1.3 (2022-12-08)

Bug Fixes

  • 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)

Features

5.1.2 (2022-12-07)

Bug Fixes

  • add-job: do not update job that already exist (#1550) (26f6311)

  • rate-limit: delete rateLimiterKey when 0 (#1553) (0b88e5b)

5.1.1 (2022-12-05)

Bug Fixes

  • remove-job: check for nil as groupId instead of empty string (#119) (dd63c23)

5.1.0 (2022-11-29)

Features

  • add support for manually rate-limit groups (64006ee)

5.0.3 (2022-11-26)

Bug Fixes

  • global-rate-limit: move job into group list (#116) (75384c4)

5.0.2 (2022-11-25)

Performance Improvements

  • groups: check rate-limit when moving job to active (#117) (d247983)

5.0.1 (2022-11-23)

Bug Fixes

  • ttl: throw error when it's not provided as positive number (#115) (2d8ef2a)

5.0.0 (2022-11-22)

Bug Fixes

BREAKING CHANGES

  • Change global rate limit Move jobs to wait or groups when global rate limit

4.0.3 (2022-11-19)

Bug Fixes

4.0.2 (2022-11-08)

Bug Fixes

4.0.1 (2022-11-07)

Features

4.0.0 (2022-10-27)

Bug Fixes

  • job: send failed event when failParentOnFailure (#1481) fixes #1469 (b20eb6f)

  • redis: replace throw exception by console.error (fafa2f8)

  • connection: validate array of strings in Cluster (#1468) fixes #1467 (8355182)

  • worker: clear stalled jobs timer when closing worker (1567a0d)

  • getters: fix return type of getJobLogs (d452927)

  • sandbox: get open port using built-in module instead of get-port (#1446) (6db6288)

  • job: update delay value when moving to wait (#1436) (9560915)

  • connection: throw error when no noeviction policy (3468390)

  • compat: remove Queue3 class (#1421) (fc797f7)

  • delayed: promote delayed jobs instead of picking one by one (1b938af)

  • delayed: remove marker when promoting delayed job (1aea0dc)

  • getters: compensate for "mark" job id (231b9aa)

  • sandbox: remove progress method (b43267b)

  • stalled-jobs: handle job id 0 (829e6e0)

  • worker: do not allow stalledInterval to be less than zero (831ffc5)

  • worker: use connection closing to determine closing status (fe1d173)

Features

  • redis-connection: allow providing scripts for extension (#1472) (f193cfb)

  • flow-producer: allow parent opts in root job when adding a flow (#1110) ref #1097 (3c3ac71)

  • job-options: add failParentOnFailure option (#1339) (65e5c36)

  • improve delayed jobs and remove QueueSchedulerPro (1f66e5a)

  • move stalled jobs check and handling to WorkerPro class from QueueSchedulerPro (13769cb)

Performance Improvements

  • scripts: pre-build scripts (#1441) (7f72603)

  • events: remove data and opts from added event (e13d4b8)

BREAKING CHANGES

  • Remove QueueSchedulerPro class. WorkerPro class should handle QueueSchedulerPro functionalities.

  • compat: The compatibility class for Bullv3 is no longer available.

  • Failed and stalled events are now produced by the WorkerPro class instead of by the QueueSchedulerPro.

  • The minimum Redis recommended version is 6.2.0.

3.0.0 (2022-10-18)

Bug Fixes

  • groups: do not parse gid when deserializing jobs fixes #25 (b03a1e9)

BREAKING CHANGES

  • groups: Group ids must be strings. Numbers are not allowed anymore.

Fixes https://github.com/taskforcesh/bullmq-pro-support/issues/25

2.7.1 (2022-10-13)

Bug Fixes

  • delete-groups: consider rate-limit, max concurrency and paused (#104) (29873f8)

2.7.0 (2022-10-11)

Features

2.6.0 (2022-10-11)

Features

2.5.0 (2022-10-11)

Features

  • add getGroupsByStatus method to getters (949e93b)

2.4.14 (2022-10-07)

Bug Fixes

  • delete-group: consider max-concurrency state (#98) (d897dd9)

2.4.13 (2022-10-05)

Bug Fixes

  • delete-group: consider rate-limit state (#97) (85f7f32)

2.4.12 (2022-09-30)

Bug Fixes

  • global-rate-limit: consider groups (#95) (de95fde)

2.4.11 (2022-09-29)

Bug Fixes

Features

2.4.10 (2022-09-14)

Bug Fixes

2.4.9 (2022-09-13)

Performance Improvements

  • script-loader: use cache to read script once (#93) (04bbeec)

2.4.8 (2022-09-09)

Bug Fixes

  • concurrency: consider base rate limit (#90) (74a4a0b)

2.4.7 (2022-09-06)

Bug Fixes

  • flow-producer-pro: use interim class (#92) (2406cc3)

2.4.6 (2022-09-06)

Performance Improvements

2.4.5 (2022-08-30)

Bug Fixes

2.4.4 (2022-08-30)

Bug Fixes

2.4.3 (2022-08-26)

Bug Fixes

  • waiting-children: consider decreasing group concurrency (#86) (be430a7)

2.4.2 (2022-08-25)

Bug Fixes

2.4.1 (2022-08-18)

Bug Fixes

2.4.0 (2022-08-16)

Features

2.3.13 (2022-08-13)

Bug Fixes

2.3.12 (2022-08-11)

Bug Fixes

  • observables: guarantee store result order (f963557)

  • observables: store last value as returnvalue (7306ae2)

2.3.11 (2022-08-09)

Bug Fixes

2.3.10 (2022-08-03)

Performance Improvements

  • move-to-finished: pass keepJobs into opts arg (#78) (08eb23f)

2.3.9 (2022-08-01)

Bug Fixes

2.3.8 (2022-08-01)

Bug Fixes

  • move-to-active: use local jobId instead of global reference (#77) (1f0b8dd)

2.3.7 (2022-07-28)

Bug Fixes

2.3.6 (2022-07-26)

Performance Improvements

  • retry-jobs: add jobs in batches when groupId is present (#72) (3961da0)

2.3.5 (2022-07-20)

Bug Fixes

2.3.4 (2022-07-16)

Bug Fixes

  • scripts: use tonumber on timestamp args (#71) (5c6a62d)

2.3.3 (2022-07-12)

Bug Fixes

2.3.2 (2022-07-09)

Bug Fixes

  • concurrency: consider retry backoff strategy (#68) (99f17bd)

2.3.1 (2022-07-01)

Bug Fixes

2.3.0 (2022-07-01)

Features

2.2.3 (2022-06-30)

Bug Fixes

  • queue-pro: fix addBulk opts typing (#66) (8b73ed9)

2.2.2 (2022-06-28)

Bug Fixes

  • pause-group: return boolean for execution success (#64) (b665b82)

2.2.1 (2022-06-25)

Bug Fixes

  • groups: rename paused and resumed events in QueueEventsPro (#63) (e2d6abf)

2.2.0 (2022-06-24)

Features

  • pause-group: allow pausing specific group (#61) ref #25 (a5ec201)

2.1.6 (2022-06-10)

Bug Fixes

2.1.5 (2022-06-09)

Bug Fixes

2.1.4 (2022-06-08)

Bug Fixes

2.1.3 (2022-05-25)

Bug Fixes

2.1.2 (2022-05-20)

Bug Fixes

2.1.1 (2022-05-18)

Bug Fixes

  • flow-producer: use JobPro instances (#54) (578d3db)

2.1.0 (2022-05-17)

Features

  • get-state: consider checking groups (#53) (1dad072)

2.0.3 (2022-05-07)

Bug Fixes

2.0.2 (2022-04-27)

Bug Fixes

  • stalled: allow easy transition for stalled changes (#50) (ce40ead)

2.0.1 (2022-04-22)

Bug Fixes

2.0.0 (2022-04-20)

Features

  • groups: improve addGroups to return all groups statuses (3f01d66)

BREAKING CHANGES

  • groups: In order to make the group getter consistent for all statuses we are changing the SET type for groups:active to ZSET. Also we rename the ZSET to groups:max as it represent groups that have maxed the concurrency.

1.4.1 (2022-04-19)

Bug Fixes

1.4.0 (2022-04-12)

Features

1.3.5 (2022-04-06)

Bug Fixes

1.3.4 (2022-03-26)

Bug Fixes

1.3.3 (2022-03-23)

Bug Fixes

1.3.2 (2022-03-16)

Bug Fixes

  • correctly handle stalled jobs when using groups (#37) (97ed889)

1.3.1 (2022-03-16)

Bug Fixes

1.3.0 (2022-03-10)

Features

  • add support for max concurrency per group (d4afb21)

1.2.5 (2022-03-08)

Bug Fixes

1.2.4 (2022-02-17)

Bug Fixes

1.2.3 (2022-02-03)

Bug Fixes

1.2.2 (2022-01-29)

Bug Fixes

1.2.1 (2022-01-13)

Bug Fixes

1.2.0 (2021-12-17)

Features

1.1.6 (2021-12-08)

Bug Fixes

  • bullmq: use fixed version for 1.55.1 (#23) (81368de)

1.1.5 (2021-12-04)

Bug Fixes

1.1.4 (2021-12-02)

Bug Fixes

1.1.3 (2021-12-01)

Bug Fixes

1.1.2 (2021-11-26)

Bug Fixes

1.1.1 (2021-11-25)

Bug Fixes

1.1.0 (2021-11-24)

Features

1.0.4 (2021-11-22)

Bug Fixes

  • add: send missing events in lua script (#13) (a6658dd)

1.0.3 (2021-11-18)

Bug Fixes

1.0.2 (2021-10-18)

Bug Fixes

  • npm: replace npm registry (01518eb)

1.0.1 (2021-10-18)

Bug Fixes

1.0.0 (2021-10-18)

Bug Fixes

Features

  • groups: initial implementation (b1da106)

  • add queue-pro, worker-pro and redis-connection-pro (b9de319)

  • initial commit (7924260)

PreviousChangelogNextNew Releases

Last updated

Was this helpful?