Changelog

v2.15.0 (2025-05-13)

Feature

• job: Add moveToCompleted method [python] (#3251) (6a8e3e2)

Fix

• worker: MaxStalledCount no less than 0 (#3249) fixes #3248 (34dcb8c)

• remove: Pass correct children meta references (#3245) (01c62ad)

Documentation

• manually-fetching: Fix typo (#3258) (1bad54a)

v2.14.0 (2025-05-01)

Feature

• flow: Support failed children in getFlow and getDependencies methods (#3243) (d3b1cff)

• flow: Support ignored children in getFlow and getDependencies methods (#3238) ref #3213 (2927803)

• queue: Add getIgnoredChildrenFailures method (#3194) (4affb11)

• job: Expose stalledCounter attribute (#3218) (9456472)

• Add removeUnprocessedChildren (#3190) (4b96266)

• flows: Add continueParentOnFailure option (#3181) (738d375)

• updateProgress: Allow more types to be used as progress (#3187) (f16b748)

• Add deduplicated job id to the deduplicated event (0f21c10)

• prometheus export: Expose global variables (0325a39)

Fix

• connection: Add str type in connection option [python] (#3212) (72fac42)

• queue-events: Omit telemetry options (#3239) (e4dac2c)

• job-scheduler: Remove next delayed job if present even if scheduler does not exist (#3203) ref #3197 (61395bf)

• deduplication: Remove deduplication key only when jobId matches with the last one being saved (#3236) (192e82c)

• flow-producer: Use FlowProducer prefix by defualt when calling getFlow (#3224) (bd17aad)

• Made line split more compatible (#3208) (3c2349a)

• job-scheduler: Fix endDate presence validation (#3195) (339f13e)

• flow: Remove job from dependencies when failParentOnFailure or continueParentOnFailure (#3201) (1fbcbec)

• flow-producer: Fix queueName otel attribute when passing it to addNode (#3198) (758ea26)

• queue-events: Pass right path for JobProgress type (#3192) fixes #3191 (33c62e6)

• flow: Validate pending dependencies before removing lock (#3182) (8d59e3b)

• job-scheduler: Emit duplicated event when next delayed job exists (#3172) (d57698f)

• scheduler: Remove next delayed job when possible (#3153) (219c0db)

• flow: Only validate pending dependencies when moving to completed (#3164) (d3c397f)

• flow: Consider prioritized state when moving a parent to failed (#3160) (d91d9f4)

Documentation

• readme: Fix typo for Job.fromId text (#3223) (9be6cbb)

• aws-elasticache: Fix typo (#3162) (702ab38)

Performance

• flow: Change parent failure in a lazy way (#3228) (6b37a37)

• flow: Validate parentKey existence before trying to move it to failed (#3163) (5a88e47)

v2.13.1 (2025-03-15)

Fix

• job-scheduler: Add marker when upserting job scheduler if needed (#3145) (0e137b2)

v2.13.0 (2025-03-15)

Feature

• job: Support ignored and failed counts in getDependenciesCount (#3137) ref #3136 (83953db)

• job: Add complete span in moveToCompleted method (#3132) (c37123c)

Fix

• job-scheduler: Restore iterationCount attribute (#3134) (eec7114)

• flow: Consider to fail a parent not in waiting-children when failParentOnFailure is provided (#3098) (589adb4)

• scheduler: Remove multi when updating a job scheduler (#3108) (4b619ca)

• job: Deserialize priority in fromJSON (#3126) (c3269b1)

Documentation

• nestjs-bullmq-pro: Update changelog to v3.1.0 (#3123) (707853c)

Performance

• worker: Optimize job retrieval for failed jobs in chunks (#3127) (e0f02ce)

v2.12.1 (2025-02-28)

Fix

• worker: Cast delay_until to integer [python] (#3116) (db617e4)

• flow: Consider delayed state when moving a parent to failed (#3112) (6a28b86)

v2.12.0 (2025-02-21)

Feature

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

Fix

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

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

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

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

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

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

Performance

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

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

v2.11.0 (2024-11-26)

Feature

• queue: Add getDelayedCount method [python] (#2934) (71ce75c)

Performance

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

v2.10.1 (2024-10-26)

Fix

• commands: Add missing build statement when releasing [python] (#2869) fixes #2868 (ff2a47b)

v2.10.0 (2024-10-24)

Feature

• job: Add getChildrenValues method [python] (#2853) (0f25213)

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

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

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

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

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

Fix

• Proper way to get version (b4e25c1)

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

v2.9.4 (2024-09-10)

Fix

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

Performance

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

v2.9.3 (2024-08-31)

Fix

• flows: Throw error when queueName contains colon (#2719) fixes #2718 (9ef97c3)

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

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

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

• connection: Remove unnecessary process.env.CI reference (#2705) (53de304)

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

v2.9.2 (2024-08-10)

Fix

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

Performance

• worker: Promote delayed jobs while queue is rate limited (#2697) ref #2582 (f3290ac)

v2.9.1 (2024-08-08)

Fix

• job: Consider passing stackTraceLimit as 0 (#2692) ref #2487 (509a36b)

v2.9.0 (2024-08-02)

Feature

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

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

• repeatable: New repeatables structure (#2617) ref #2612 fixes #2399 #2596 (8376a9a)

• queue: Support global concurrency (#2496) ref #2465 (47ba055)

Fix

• job: Make sure json.dumps return JSON compliant JSON [python] (#2683) (4441711)

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

Performance

• worker: Fetch next job on failure (#2342) (f917b80)

v2.8.1 (2024-07-11)

Fix

• delayed: Avoid using jobId in order to schedule delayed jobs (#2587) (python) (228db2c)

Performance

• delayed: Keep moving delayed jobs to waiting when queue is paused (#2640) (python) (b89e2e0)

v2.8.0 (2024-07-10)

Feature

• queue: Add getCountsPerPriority method [python] (#2607) (02b8338)

Fix

• parent: Consider re-adding child that is in completed state using same jobIds (#2627) (python) fixes #2554 (00cd017)

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

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

v2.7.8 (2024-06-05)

Fix

• Remove print calls [python] (#2579) (f957186)

v2.7.7 (2024-06-04)

Fix

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

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

Performance

• job: Set processedBy using hmset (#2592) (python) (238680b)

v2.7.6 (2024-05-09)

Fix

• connection: Use async Retry (#2555) [python] (d6dd21d)

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

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

v2.7.5 (2024-04-28)

Fix

• worker: Wait for jobs to finalize on close (#2545) [python] (d81f210)

v2.7.4 (2024-04-26)

Fix

• redis-connection: Increase redis retry strategy backoff (#2546) [python] (6cf7712)

v2.7.3 (2024-04-24)

Fix

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

v2.7.2 (2024-04-20)

Fix

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

v2.7.1 (2024-04-18)

Fix

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

v2.7.0 (2024-04-13)

Feature

• queue: Add getJobLogs method [python] (#2523) ref #2472 (a24a16e)

v2.6.0 (2024-04-13)

Feature

• worker: Use 0.002 as minimum timeout for redis version lower than 7.0.8 [python] (#2521) (f3862dd)

• Allow arbitrary large drainDelay (9693321)

Fix

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

v2.5.0 (2024-04-08)

Feature

• python: Support reusable redis connections (29ad8c8)

v2.4.0 (2024-04-07)

Performance

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

v2.3.3 (2024-03-24)

Fix

• connection: Accept all parameters for redis connection [python] (#2486) (ce30192)

v2.3.2 (2024-03-23)

Fix

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

v2.3.1 (2024-03-19)

Fix

• worker: Set blockTimeout as 0.001 when reach the time to get delayed jobs [python] (#2478) (b385034)

v2.3.0 (2024-03-16)

Feature

• job: Add log method [python] (#2476) ref #2472 (34946c4)

v2.2.4 (2024-02-13)

Fix

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

v2.2.3 (2024-02-10)

Performance

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

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

v2.2.2 (2024-02-03)

Fix

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

Performance

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

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

v2.2.1 (2024-01-16)

Fix

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

v2.2.0 (2024-01-14)

Feature

• queue: Add promoteJobs method [python] (#2377) (3b9de96)

v2.1.0 (2024-01-12)

Feature

• repeatable: Allow saving custom key (#1824) (8ea0e1f)

Fix

• redis: Upgrade to v5 [python] (#2364) (d5113c8)

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

v2.0.0 (2023-12-23)

Feature

• job: Add isActive method [python] (#2352) (afb5e31)

• job: separate attemptsMade from attemptsStarted when manually moving a job (#2203) (0e88e4f)

• scripts: Use new queue markers (4276eb7)

• worker: Improved markers handling (73cf5fc) (0bac0fb)

Fix

• connection: Unify redis connection args for Queue and Worker (#2282) (8eee20f)

Breaking

• Markers use now a dedicated key in redis instead of using a special Job ID. (73cf5fc) (0bac0fb)

• Connection must be provided as part of options (#2282) (8eee20f)

v1.24.0 (2023-12-21)

Feature

• job: Add isWaitingChildren method [python] (#2345) (e9c1fa1)

v1.23.0 (2023-12-18)

Feature

• queue: Add getRateLimitTtl method [python] (#2340) (f0a1f70)

v1.22.0 (2023-12-14)

Feature

• job: Add isFailed method [python] (#2333) (19bfccc)

v1.21.0 (2023-12-14)

Feature

• job: Add isCompleted method [python] (#2331) (364f0c1)

v1.20.0 (2023-12-13)

Feature

• job: Add isWaiting method [python] (#2328) (5db9f95)

v1.19.0 (2023-12-12)

Feature

• job: Add promote method [python] (#2323) (61f4ba3)

v1.18.0 (2023-12-10)

Fix

• retry: Pass right redis command name into retryJob script (#2321) [python] (6bb21a0)

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

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

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

v1.17.0 (2023-11-24)

Feature

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

Fix

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

v1.16.1 (2023-11-09)

Fix

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

v1.16.0 (2023-11-08)

Fix

• backoff: Fix builtin backoff type (#2265) [python] (76959eb)

v1.15.4 (2023-11-05)

Fix

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

v1.15.3 (2023-11-05)

Fix

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

v1.15.2 (2023-10-18)

Fix

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

• events: Trim events when retrying a job (#2224) (1986b05)

Performance

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

v1.15.1 (2023-10-04)

Fix

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

v1.15.0 (2023-09-30)

Feature

• Nothing change

v1.14.0 (2023-09-26)

Feature

• queue: Add clean method [python] (#2194) (3b67193)

Fix

• move-to-finished: Stringify any return value [python] (#2198) fixes #2196 (07f1335)

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

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

v1.13.2 (2023-09-12)

Fix

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

v1.13.1 (2023-09-11)

Fix

• move-to-finished: Consider addition of prioritized jobs when processing last active job (#2176) (python) (4b01f35)

v1.13.0 (2023-09-07)

Feature

• flow-producer: Add addBulk method (python) (#2174) (c67dfb4)

v1.12.0 (2023-08-31)

Feature

• queue: Add addBulk method (#2161) (555dd44)

v1.11.0 (2023-08-26)

Feature

• Add flow producer class (#2115) (14a769b)

v1.10.1 (2023-08-19)

Fix

• job: Job getReturnValue not returning returnvalue (#2143) (dcb8e6a)

Performance

• rate-limit: Get pttl only if needed (#2129) (12ce2f3)

v1.10.0 (2023-08-03)

Feature

• redis-connection: Add username option into redisOpts (#2108) (d27f33e)

Performance

• retry: Compare prev state instead of regex expression (#2099) (c141283)

v1.9.0 (2023-07-18)

Feature

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

v1.8.0 (2023-07-17)

Fix

• worker: Respect concurrency (#2062) fixes #2063 (1b95185)

v1.7.0 (2023-07-14)

Feature

• queue: Add remove method (#2066) (808ee72)

• worker: Add id as part of token (#2061) (e255356)

v1.6.1 (2023-07-10)

Fix

• pyproject: Add requires-python config (#2056) fixes #1979 (a557970)

v1.6.0 (2023-07-06)

Feature

• job: Add moveToWaitingChildren method (#2049) (6d0e224)

v1.5.0 (2023-07-04)

Fix

• queue: Fix isPaused method when custom prefix is present (#2047) (7ec1c5b)

v1.4.0 (2023-06-30)

Feature

• queue: Add getJobState method (#2040) (8ec9ed6)

v1.3.1 (2023-06-29)

Fix

• pyproject: Build egg-info at the root location (3c2d06e)

v1.3.0 (2023-06-29)

Feature

• queue: Add getFailedCount method (#2036) (92d7227)

• queue: Add getCompletedCount method (#2033) (3e9db5e)

Fix

• release: Add recommended pyproject.toml configuration (#2029) (d03ffc9)

v1.2.0 (2023-06-24)

Feature

• queue: Add get job methods by state (#2012) (57b2b72)

v1.1.0 (2023-06-23)

Feature

• queue: Add getJobs method (#2011) (8d5d6c1)

v1.0.0 (2023-06-21)

Breaking

• priority is separeted in its own zset, no duplication needed (42a890a)

Performance

• priority: Add prioritized as a new state (#1984) (python) (42a890a)

v0.5.6 (2023-06-21)

Fix

• queue: Pass right params to trimEvents method (#2004) (a55fd77)

v0.5.5 (2023-06-16)

Fix

• rate-limit: Keep priority fifo order (#1991) fixes #1929 (python) (56bd7ad)

• worker: Set redis version always in initialization (#1989) fixes #1988 (a1544a8)

v0.5.4 (2023-06-14)

Fix

• connection: Add retry strategy in connection (#1975) (7c5ee20)

v0.5.3 (2023-06-13)

Fix

• worker: Use timeout as integer for redis lower than v6.0.0 (python) (#1981) (0df6afa)

v0.5.2 (2023-06-11)

Fix

• retry-job: Consider priority when moving job to wait (python) (#1969) (e753855)

v0.5.1 (2023-06-09)

Fix

• python: Include lua scripts when releasing (bb4f3b2)

v0.5.0 (2023-06-09)

Feature

• python: Add remove job method (#1965) (6a172e9)

v0.4.4 (2023-06-08)

Fix

• deps: Downgrade python-semantic-release to avoid version issue

v0.4.3 (2023-06-07)

Feature

• Add changePriority method (#1943) (945bcd3)

Fix

• rate-limit: Consider paused queue (#1931) (d97864a)

v0.4.2 (2023-06-01)

Fix

• deps: Fix 'install_requires' to include semver (#1927) (ce86ece)

v0.4.1 (2023-05-29)

Feature

• job: Add getState method (#1906) (f0867a6)

v0.4.0 (2023-05-18)

Feature

• connection: accept redis options as string (01f549e)

• job: add moveToDelayed job method (#1849) (5bebf8d)

• job: Add retry method into job (#1877) (870da45)

• job: Add updateData method (#1871) (800b8c4)

• job: Add updateProgress method in job class(#1830) (e1e1aa2)

• job: Save stacktrace when job fails (#1859) (0b538ce)

• Support retryJob logic (#1869) (b044a03)

Fix

• retry: Consider when queue is paused (#1880) (01b621f)

• worker: Stop processes when force stop (#1837) (514699c)

v0.3.0 (2023-04-18)

Feature

• queue: Add getJobCounts method (#1807) (46d6f94)

• Improve worker concurrency (#1809) (ec7c49e)

Fix

• Correct condition so that the worker keeps processing jobs indefinitely (#1800) (ef0c5d6)

• Fix scripts typing on array2obj function (#1786) (134f6ab)

• Pass maxMetricsSize as empty string when it is not provided fixes (#1754) (6bda2b2)

v0.2.0 (2023-03-29)

Feature

• Add trimEvents method (#1695) (ca48163)

• queue: Add retryJobs method (#1688) (2745327)

v0.1.0 (2023-02-15)

Feature

• Initial python package (a97b22f)