BullMQ
  • What is BullMQ
  • Quick Start
  • API Reference
  • Changelogs
    • v4
    • v3
    • v2
    • v1
  • Guide
    • Introduction
    • Connections
    • Queues
      • Auto-removal of jobs
      • Adding jobs in bulk
      • Global Concurrency
      • Removing Jobs
    • Workers
      • Auto-removal of jobs
      • Concurrency
      • Graceful shutdown
      • Stalled Jobs
      • Sandboxed processors
      • Pausing queues
    • Jobs
      • FIFO
      • LIFO
      • Job Ids
      • Job Data
      • Deduplication
      • Delayed
      • Repeatable
      • Prioritized
      • Removing jobs
      • Stalled
      • Getters
    • Job Schedulers
      • Repeat Strategies
      • Repeat options
      • Manage Job Schedulers
    • Flows
      • Adding flows in bulk
      • Get Flow Tree
      • Fail Parent
      • Continue Parent
      • Remove Dependency
      • Ignore Dependency
      • Remove Child Dependency
    • Metrics
      • Prometheus
    • Rate limiting
    • Parallelism and Concurrency
    • Retrying failing jobs
    • Returning job data
    • Events
      • Create Custom Events
    • Telemetry
      • Getting started
      • Running Jaeger
      • Running a simple example
    • QueueScheduler
    • Redisâ„¢ Compatibility
      • Dragonfly
    • Redisâ„¢ hosting
      • AWS MemoryDB
      • AWS Elasticache
    • Architecture
    • NestJs
      • Producers
      • Queue Events Listeners
    • Going to production
    • Migration to newer versions
    • Troubleshooting
  • Patterns
    • Adding jobs in bulk across different queues
    • Manually processing jobs
    • Named Processor
    • Flows
    • Idempotent jobs
    • Throttle jobs
    • Process Step Jobs
    • Failing fast when Redis is down
    • Stop retrying jobs
    • Timeout jobs
    • Timeout for Sandboxed processors
    • Redis Cluster
  • BullMQ Pro
    • Introduction
    • Install
    • Observables
      • Cancelation
    • Groups
      • Getters
      • Rate limiting
      • Local group rate limit
      • Concurrency
      • Local group concurrency
      • Max group size
      • Pausing groups
      • Prioritized intra-groups
      • Sandboxes for groups
    • Telemetry
    • Batches
    • NestJs
      • Producers
      • Queue Events Listeners
      • API Reference
      • Changelog
    • API Reference
    • Changelog
    • New Releases
    • Support
  • Bull
    • Introduction
    • Install
    • Quick Guide
    • Important Notes
    • Reference
    • Patterns
      • Persistent connections
      • Message queue
      • Returning Job Completions
      • Reusing Redis Connections
      • Redis cluster
      • Custom backoff strategy
      • Debugging
      • Manually fetching jobs
  • Python
    • Introduction
    • Changelog
Powered by GitBook

Copyright (c) Taskforce.sh Inc.

On this page
  • 5.52.2 (2025-05-08)
  • 5.52.1 (2025-05-02)
  • 5.52.0 (2025-05-01)
  • 5.51.1 (2025-04-26)
  • 5.51.0 (2025-04-25)
  • 5.50.0 (2025-04-25)
  • 5.49.2 (2025-04-21)
  • 5.49.1 (2025-04-17)
  • 5.49.0 (2025-04-16)
  • 5.48.1 (2025-04-10)
  • 5.48.0 (2025-04-08)
  • 5.47.3 (2025-04-08)
  • 5.47.2 (2025-04-06)
  • 5.47.1 (2025-04-05)
  • 5.47.0 (2025-04-04)
  • 5.46.1 (2025-04-03)
  • 5.46.0 (2025-04-02)
  • 5.45.2 (2025-03-29)
  • 5.45.1 (2025-03-29)
  • 5.45.0 (2025-03-27)
  • 5.44.4 (2025-03-24)
  • 5.44.3 (2025-03-22)
  • 5.44.2 (2025-03-22)
  • 5.44.1 (2025-03-21)
  • 5.44.0 (2025-03-18)
  • 5.43.1 (2025-03-15)
  • 5.43.0 (2025-03-13)
  • 5.42.0 (2025-03-12)
  • 5.41.9 (2025-03-11)
  • 5.41.8 (2025-03-08)
  • 5.41.7 (2025-02-27)
  • 5.41.6 (2025-02-26)
  • 5.41.5 (2025-02-21)
  • 5.41.4 (2025-02-21)
  • 5.41.3 (2025-02-19)
  • 5.41.2 (2025-02-16)
  • 5.41.1 (2025-02-15)
  • 5.41.0 (2025-02-14)
  • 5.40.5 (2025-02-14)
  • 5.40.4 (2025-02-13)
  • 5.40.3 (2025-02-12)
  • 5.40.2 (2025-02-07)
  • 5.40.1 (2025-02-07)
  • 5.40.0 (2025-02-02)
  • 5.39.2 (2025-02-02)
  • 5.39.1 (2025-01-30)
  • 5.39.0 (2025-01-29)
  • 5.38.0 (2025-01-28)
  • 5.37.0 (2025-01-25)
  • 5.36.0 (2025-01-24)
  • 5.35.1 (2025-01-23)
  • 5.35.0 (2025-01-22)
  • 5.34.10 (2025-01-14)
  • 5.34.9 (2025-01-12)
  • 5.34.8 (2025-01-08)
  • 5.34.7 (2025-01-06)
  • 5.34.6 (2024-12-31)
  • 5.34.5 (2024-12-25)
  • 5.34.4 (2024-12-21)
  • 5.34.3 (2024-12-18)
  • 5.34.2 (2024-12-14)
  • 5.34.1 (2024-12-13)
  • 5.34.0 (2024-12-10)
  • 5.33.1 (2024-12-10)
  • 5.33.0 (2024-12-09)
  • 5.32.0 (2024-12-08)
  • 5.31.2 (2024-12-06)
  • 5.31.1 (2024-12-04)
  • 5.31.0 (2024-12-02)
  • 5.30.1 (2024-11-30)
  • 5.30.0 (2024-11-29)
  • 5.29.1 (2024-11-23)
  • 5.29.0 (2024-11-22)
  • 5.28.2 (2024-11-22)
  • 5.28.1 (2024-11-20)
  • 5.28.0 (2024-11-19)
  • 5.27.0 (2024-11-19)
  • 5.26.2 (2024-11-15)
  • 5.26.1 (2024-11-14)
  • 5.26.0 (2024-11-14)
  • 5.25.6 (2024-11-11)
  • 5.25.5 (2024-11-11)
  • 5.25.4 (2024-11-10)
  • 5.25.3 (2024-11-08)
  • 5.25.2 (2024-11-08)
  • 5.25.1 (2024-11-07)
  • 5.25.0 (2024-11-06)
  • 5.24.0 (2024-11-05)
  • 5.23.1 (2024-11-05)
  • 5.23.0 (2024-11-02)
  • 5.22.0 (2024-10-31)
  • 5.21.2 (2024-10-22)
  • 5.21.1 (2024-10-18)
  • 5.21.0 (2024-10-18)
  • 5.20.1 (2024-10-18)
  • 5.20.0 (2024-10-13)
  • 5.19.1 (2024-10-12)
  • 5.19.0 (2024-10-11)
  • 5.18.0 (2024-10-09)
  • 5.17.1 (2024-10-07)
  • 5.17.0 (2024-10-07)
  • 5.16.0 (2024-10-06)
  • 5.15.0 (2024-10-01)
  • 5.14.0 (2024-09-30)
  • 5.13.2 (2024-09-20)
  • 5.13.1 (2024-09-18)
  • 5.13.0 (2024-09-11)
  • 5.12.15 (2024-09-10)
  • 5.12.14 (2024-09-05)
  • 5.12.13 (2024-09-03)
  • 5.12.12 (2024-08-29)
  • 5.12.11 (2024-08-28)
  • 5.12.10 (2024-08-22)
  • 5.12.9 (2024-08-17)
  • 5.12.8 (2024-08-17)
  • 5.12.7 (2024-08-16)
  • 5.12.6 (2024-08-14)
  • 5.12.5 (2024-08-13)
  • 5.12.4 (2024-08-12)
  • 5.12.3 (2024-08-10)
  • 5.12.2 (2024-08-09)
  • 5.12.1 (2024-08-07)
  • 5.12.0 (2024-08-01)
  • 5.11.0 (2024-07-29)
  • 5.10.4 (2024-07-26)
  • 5.10.3 (2024-07-19)
  • 5.10.2 (2024-07-19)
  • 5.10.1 (2024-07-18)
  • 5.10.0 (2024-07-16)
  • 5.9.0 (2024-07-15)
  • 5.8.7 (2024-07-11)
  • 5.8.6 (2024-07-11)
  • 5.8.5 (2024-07-10)
  • 5.8.4 (2024-07-05)
  • 5.8.3 (2024-06-28)
  • 5.8.2 (2024-06-15)
  • 5.8.1 (2024-06-12)
  • 5.8.0 (2024-06-11)
  • 5.7.15 (2024-06-04)
  • 5.7.14 (2024-05-29)
  • 5.7.13 (2024-05-28)
  • 5.7.12 (2024-05-24)
  • 5.7.11 (2024-05-23)
  • 5.7.10 (2024-05-21)
  • 5.7.9 (2024-05-16)
  • 5.7.8 (2024-05-01)
  • 5.7.7 (2024-04-30)
  • 5.7.6 (2024-04-27)
  • 5.7.5 (2024-04-24)
  • 5.7.4 (2024-04-21)
  • 5.7.3 (2024-04-20)
  • 5.7.2 (2024-04-18)
  • 5.7.1 (2024-04-10)
  • 5.7.0 (2024-04-09)
  • 5.6.0 (2024-04-08)
  • 5.5.4 (2024-04-07)
  • 5.5.3 (2024-04-07)
  • 5.5.2 (2024-04-06)
  • 5.5.1 (2024-04-03)
  • 5.5.0 (2024-03-31)
  • 5.4.6 (2024-03-26)
  • 5.4.5 (2024-03-22)
  • 5.4.4 (2024-03-21)
  • 5.4.3 (2024-03-17)
  • 5.4.2 (2024-03-06)
  • 5.4.1 (2024-03-01)
  • 5.4.0 (2024-02-27)
  • 5.3.3 (2024-02-25)
  • 5.3.2 (2024-02-24)
  • 5.3.1 (2024-02-22)
  • 5.3.0 (2024-02-20)
  • 5.2.1 (2024-02-17)
  • 5.2.0 (2024-02-17)
  • 5.1.12 (2024-02-16)
  • 5.1.11 (2024-02-13)
  • 5.1.10 (2024-02-10)
  • 5.1.9 (2024-02-05)
  • 5.1.8 (2024-02-03)
  • 5.1.7 (2024-02-02)
  • 5.1.6 (2024-01-31)
  • 5.1.5 (2024-01-23)
  • 5.1.4 (2024-01-20)
  • 5.1.3 (2024-01-16)
  • 5.1.2 (2024-01-15)
  • 5.1.1 (2024-01-02)
  • 5.1.0 (2023-12-27)
  • 5.0.0 (2023-12-21)

Was this helpful?

Changelogs

PreviousQuick StartNextv4

Last updated 4 days ago

Was this helpful?

(2025-05-08)

Bug Fixes

  • worker: maxStalledCount no less than 0 () fixes ()

(2025-05-02)

Bug Fixes

  • remove: pass correct children meta references () ()

(2025-05-01)

Bug Fixes

  • connection: add str type in connection option [python] () ()

Features

  • flow: support failed children in getFlow and getDependencies methods () ()

(2025-04-26)

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Performance Improvements

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Features

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Features

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Features

Features

Bug Fixes

Features

Bug Fixes

Bug Fixes

Performance Improvements

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Bug Fixes

Features

Features

Performance Improvements

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Features

Bug Fixes

Features

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Features

Features

Bug Fixes

Bug Fixes

Features

Features

Features

Features

Bug Fixes

Bug Fixes

Features

Bug Fixes

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Features

Features

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Features

Features

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Features

Features

  • Nothing change, triggered by a python version release

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

Bug Fixes

Bug Fixes

Performance Improvements

Performance Improvements

Performance Improvements

Bug Fixes

Bug Fixes

Performance Improvements

Bug Fixes

Bug Fixes

Bug Fixes

Bug Fixes

Features

Bug Fixes

Features

BREAKING CHANGES

  • worker: Markers use now a dedicated key in redis instead of using a special Job ID.

  • references:

queue-events: omit telemetry options () ()

(2025-04-25)

job-scheduler: remove next delayed job if present even if scheduler does not exist () ref ()

flow: support ignored children in getFlow and getDependencies methods () ref ()

(2025-04-25)

deduplication: remove deduplication key only when jobId matches with the last one being saved () ()

queue: add getIgnoredChildrenFailures method () ()

(2025-04-21)

flow: change parent failure in a lazy way () ()

(2025-04-17)

flow-producer: use FlowProducer prefix by defualt when calling getFlow () ()

(2025-04-16)

job: expose stalledCounter attribute () ()

(2025-04-10)

made line split more compatible () (), closes

(2025-04-08)

add removeUnprocessedChildren () ()

(2025-04-08)

job-scheduler: fix endDate presence validation () ()

(2025-04-06)

flow: remove job from dependencies when failParentOnFailure or continueParentOnFailure () ()

(2025-04-05)

flow-producer: fix queueName otel attribute when passing it to addNode () ()

(2025-04-04)

flows: add continueParentOnFailure option () ()

(2025-04-03)

queue-events: pass right path for JobProgress type () fixes ()

(2025-04-02)

updateProgress: allow more types to be used as progress () ()

(2025-03-29)

flow: validate pending dependencies before removing lock () ()

(2025-03-29)

job-scheduler: emit duplicated event when next delayed job exists () ()

(2025-03-27)

add deduplicated job id to the deduplicated event ()

(2025-03-24)

scheduler: remove next delayed job when possible () ()

(2025-03-22)

flow: only validate pending dependencies when moving to completed () ()

(2025-03-22)

flow: validate parentKey existence before trying to move it to failed () ()

(2025-03-21)

flow: consider prioritized state when moving a parent to failed () ()

(2025-03-18)

prometheus export: expose global variables ()

(2025-03-15)

job-scheduler: add marker when upserting job scheduler if needed () ()

(2025-03-13)

job: support ignored and failed counts in getDependenciesCount () ref ()

(2025-03-12)

flow: consider to fail a parent not in waiting-children when failParentOnFailure is provided () ()

job-scheduler: restore iterationCount attribute () ()

job: add complete span in moveToCompleted method () ()

worker: optimize job retrieval for failed jobs in chunks () ()

(2025-03-11)

scheduler: remove multi when updating a job scheduler () ()

(2025-03-08)

job: deserialize priority in fromJSON () ()

worker: cast delay_until to integer [python] () ()

(2025-02-27)

scheduler: validate repeatKey if present when cleaning failed jobs () fixes ()

(2025-02-26)

flow: consider delayed state when moving a parent to failed () ()

telemetry: fix span name for moveToFailed logic () ()

(2025-02-21)

job-scheduler: consider removing current job from wait, paused or prioritized () ()

(2025-02-21)

delayed: add marker once when promoting delayed jobs () (python) ()

(2025-02-19)

worker: do not execute run method when no processor is defined when resuming () ()

(2025-02-16)

worker: do not resume when closing () ()

(2025-02-15)

job: set processedBy when moving job to active in moveToFinished () fixes ()

(2025-02-14)

job: add moveToWait method for manual processing () ()

queue: support removeGlobalConcurrency method () ()

add-job: add job into wait or prioritized state when delay is provided as 0 () ()

(2025-02-14)

drain: pass delayed key for redis cluster () ()

(2025-02-13)

job-scheduler: restore limit option to be saved () ()

(2025-02-12)

job-scheduler: return undefined in getJobScheduler when it does not exist () fixes ()

(2025-02-07)

fix return type of getNextJob ()

(2025-02-07)

worker: wait fetched jobs to be processed when closing () ()

(2025-02-02)

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

(2025-02-02)

worker: evaluate if a job needs to be fetched when moving to failed () ()

(2025-01-30)

retry-job: consider updating failures in job () ()

(2025-01-29)

job-scheduler: save limit option () ()

(2025-01-28)

flow-producer: add support for skipWaitingForReady ()

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

(2025-01-25)

queue-getters: add prometheus exporter ()

(2025-01-24)

job-scheduler: save iteration count () ()

(2025-01-23)

worker: avoid possible hazard in closing worker ()

(2025-01-22)

sandbox: add support for getChildrenValues ()

(2025-01-14)

job-scheduler: use delayed job data when template data is not present () fixes ()

(2025-01-12)

job-scheduler: add next delayed job only when prevMillis matches with producerId () ()

(2025-01-08)

job-scheduler: add delayed job and update scheduler in same script () ()

(2025-01-06)

job-scheduler: add delayed job and scheduler in same script () ()

(2024-12-31)

job-scheduler: avoid duplicates when upserting in a quick sequence () ()

(2024-12-25)

dynamic-rate-limit: validate job lock cases () ()

(2024-12-21)

sandbox: fix issue where job could stay in active forever () ()

(2024-12-18)

sandboxed: fix detecting special errors by sending default messages () fixes ()

(2024-12-14)

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

(2024-12-13)

guarantee every repeatable jobs are slotted ()

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

(2024-12-10)

telemetry: add option to omit context propagation on jobs () ()

(2024-12-10)

job-scheduler: omit deduplication and debounce options from template options () ()

(2024-12-09)

replace multi by lua scripts in moveToFailed () ()

(2024-12-08)

queue: enhance getJobSchedulers method to include template information () ref ()

(2024-12-06)

worker: catch connection error when moveToActive is called () ()

(2024-12-04)

scheduler-template: remove console.log when getting template information () ()

(2024-12-02)

queue: enhance getJobScheduler method to include template information () ref ()

(2024-11-30)

flow: allow using removeOnFail and failParentOnFailure in parents () fixes ()

(2024-11-29)

job-scheduler: upsert template when same pattern options are provided () ref ()

queue: add getJobSchedulersCount method () ()

(2024-11-23)

scheduler: remove deprecation warning on immediately option () ()

(2024-11-22)

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

(2024-11-22)

queue: change _jobScheduler from private to protected for extension () ()

(2024-11-20)

scheduler: use Job class from getter for extension () ()

(2024-11-19)

job-scheduler: add telemetry support to the job scheduler ()

(2024-11-19)

queue: add rateLimit method () ()

queue: add removeRateLimitKey method () ()

marker: add base markers while consuming jobs to get workers busy () fixes ()

(2024-11-15)

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

(2024-11-14)

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

(2024-11-14)

improve queue getters to use generic job type () ()

(2024-11-11)

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

(2024-11-11)

connection: do not allow to set blockingConnection option () ()

(2024-11-10)

repeatable: only apply immediately in the first iteration ()

(2024-11-08)

scripts: set package version by default for extension () ()

(2024-11-08)

worker: allow retrieving concurrency value () fixes ()

(2024-11-07)

connection: set packageVersion as protected attribute for extension () ()

(2024-11-06)

queue-events: add QueueEventsProducer for publishing custom events () ()

(2024-11-05)

flows: add telemetry support () ()

(2024-11-05)

deps: bump msgpackr to 1.1.2 to resolve ERR_BUFFER_OUT_OF_BOUNDS error () ref ()

(2024-11-02)

scheduler: add getJobScheduler method () ref ()

(2024-10-31)

queue: add a telemetry interface () ()

(2024-10-22)

proper way to get version ()

(2024-10-18)

scripts: add missing wait in isJobInList ()

(2024-10-18)

queue: add option to skip metas update ()

(2024-10-18)

redis: use version for naming loaded lua scripts ()

(2024-10-13)

queue: add queue version support () ()

(2024-10-12)

sandbox: fix serialization of error with circular references are present () fix ()

(2024-10-11)

repeat: deprecate immediately on job scheduler ()

(2024-10-09)

job: expose priority value () ()

(2024-10-07)

repeat: also consider startDate when using "every" ()

(2024-10-07)

sandbox: catch exit errors () ()

job: add deduplication logic () ()

(2024-10-06)

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

(2024-10-01)

worker-fork: allow passing fork options () ()

(2024-09-30)

worker-thread: allow passing Worker options () ref ()

(2024-09-20)

repeatable: avoid delayed job deletion if next job already existed () ()

(2024-09-18)

connection: allow passing connection string into IORedis () ()

(2024-09-11)

queue: add getDebounceJobId method () ()

(2024-09-10)

metrics: differentiate points in different minutes to be more accurate () (python) ()

pattern: do not save offset when immediately is provided () ()

(2024-09-05)

metrics: save zeros as much as max data points () ()

(2024-09-03)

repeat: replace delayed job when updating repeat key ()

(2024-08-29)

flows: throw error when queueName contains colon () fixes ()

(2024-08-28)

sandboxed: properly update data on wrapped job () fixes ()

(2024-08-22)

flow: remove debounce key when parent is moved to fail () ()

(2024-08-17)

fifo-queue: use linked list structure for queue () ()

(2024-08-17)

flow: recursive ignoreDependencyOnFailure option () ()

(2024-08-16)

job: throw error if removeDependencyOnFailure and ignoreDependencyOnFailure are used together () ()

(2024-08-14)

job: change moveToFinished return type to reflect jobData () ref ()

stalled: support removeDependencyOnFailure option when job is stalled () ()

(2024-08-13)

connection: remove unnecessary process.env.CI reference () ()

(2024-08-12)

worker: fix close sequence to reduce risk for open handlers () ()

(2024-08-10)

flow: validate parentData before ignoreDependencyOnFailure when stalled check happens () (python) ()

(2024-08-09)

worker: promote delayed jobs while queue is rate limited () ref ()

(2024-08-07)

job: consider passing stackTraceLimit as 0 () ref ()

(2024-08-01)

queue-events: pass debounceId as a param of debounced event () ()

(2024-07-29)

job: allow passing debounce as option () ()

(2024-07-26)

repeatable: remove repeat hash when removing repeatable job () ()

(2024-07-19)

repeatable: keep legacy repeatables if it exists instead of creating one with new structure () ()

(2024-07-19)

worker: fetch next job on failure () ()

(2024-07-18)

repeatable: consider removing legacy repeatable job () fixes ()

repeatable: pass custom key as an args in addRepeatableJob to prevent CROSSSLOT issue () fixes ()

(2024-07-16)

repeatable: new repeatables structure () ref fixes ()

(2024-07-15)

queue: support global concurrency () ref ()

(2024-07-11)

delayed: keep moving delayed jobs to waiting when queue is paused () (python) ()

(2024-07-11)

delayed: avoid using jobId in order to schedule delayed jobs () (python) ()

(2024-07-10)

parent: consider re-adding child that is in completed state using same jobIds () (python) fixes ()

(2024-07-05)

queue-getters: consider passing maxJobs when calling getRateLimitTtl () fixes ()

(2024-06-28)

job: consider changing priority to 0 () ()

(2024-06-15)

priority: consider paused state when calling getCountsPerPriority (python) () ()

(2024-06-12)

priority: use module instead of bit.band to keep order (python) () ()

(2024-06-11)

queue: add getCountsPerPriority method () ()

(2024-06-04)

job: set processedBy using hmset () (python) ()

(2024-05-29)

worker: properly cancel blocking command during disconnections ()

(2024-05-28)

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

(2024-05-24)

repeat: throw error when endDate is pointing to the past () ()

(2024-05-23)

retry-job: throw error when job is not in active state () ()

(2024-05-21)

sandboxed: ensure DelayedError is checked in Sandboxed processors () fixes ()

(2024-05-16)

job: validate job existence when adding a log () ()

(2024-05-01)

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

(2024-04-30)

worker: force timeout on bzpopmin command () ()

(2024-04-27)

worker: do not call bzpopmin when blockDelay is lower or equal 0 () ref ()

(2024-04-24)

stalled: consider ignoreDependencyOnFailure option (python) () fixes ()

(2024-04-21)

worker: reset delays after generating blockTimeout value () ()

(2024-04-20)

worker: return minimumBlockTimeout depending on redis version (python) () ()

(2024-04-18)

stalled: consider failParentOnFailure when moving child into failed () fixes (python) ()

(2024-04-10)

worker: use 0.002 as minimum timeout for redis version lower than 7.0.8 () fixes ()

(2024-04-09)

allow arbitrary large drainDelay ()

(2024-04-08)

(2024-04-07)

stalled: remove jobId from stalled after removing lock when moved from active () (python) ()

(2024-04-07)

deps: remove script loader from dist as it is used only when building package () ()

(2024-04-06)

client: try catch list command as it's not supported in GCP () ()

(2024-04-03)

connection: ignore error when setting custom end status () ()

(2024-03-31)

getters: add getWorkersCount ()

(2024-03-26)

job: stack trace limit () ()

(2024-03-22)

scripts: use command name in error message when moving to finished () ()

(2024-03-21)

queue: use QueueOptions type in opts attribute () ()

(2024-03-17)

worker: validate drainDelay must be greater than 0 () ()

(2024-03-06)

move fast-glob and minimatch as dev-dependencies () ()

(2024-03-01)

worker: set blockTimeout as 0.001 when reach the time to get delayed jobs () fixes ()

(2024-02-27)

job: add removeChildDependency method () ()

(2024-02-25)

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

(2024-02-24)

sandbox: extend SandboxedJob from JobJsonSandbox () fixes ()

(2024-02-22)

add-job: fix parent job cannot be replaced error message () ()

(2024-02-20)

worker: add support for naming workers ()

(2024-02-17)

flow: remove failed children references on auto removal () ()

(2024-02-17)

flow: add ignoreDependencyOnFailure option () ()

(2024-02-16)

redis-connection: close redis connection even when initializing () fixes ()

(2024-02-13)

flow: parent job cannot be replaced (python) () ()

(2024-02-10)

marker: differentiate standard and delayed markers (python) () ()

(2024-02-05)

change-delay: add delay marker when needed () ()

(2024-02-03)

flow: add marker when moving parent to wait (python) () ()

(2024-02-02)

reprocess-job: add marker if needed () ()

(2024-01-31)

rate-limit: move job to wait even if ttl is 0 () ()

(2024-01-23)

move-to-active: check rate limited once () ()

(2024-01-20)

stalled: consider adding marker when moving job back to wait () ()

(2024-01-16)

retry-jobs: add marker when needed () ()

(2024-01-15)

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

(2024-01-02)

worker: worker can be closed if Redis is down () ()

(2023-12-27)

repeatable: allow saving custom key () ()

(2023-12-21)

worker: throw error if connection is missing ()

job: provide skipAttempt option when manually moving a job () ()

worker: improved markers handling () ()

connection: require connection to be passed () ()

job: revert console warn custom job ids when they represent integers () ()

5.52.2
#3249
#3248
34dcb8c
5.52.1
#3245
01c62ad
5.52.0
#3212
72fac42
#3243
d3b1cff
5.51.1
#3239
e4dac2c
5.51.0
#3203
#3197
61395bf
#3238
#3213
2927803
5.50.0
#3236
192e82c
#3194
4affb11
5.49.2
#3228
6b37a37
5.49.1
#3224
bd17aad
5.49.0
#3218
9456472
5.48.1
#3208
3c2349a
#3204
5.48.0
#3190
4b96266
5.47.3
#3195
339f13e
5.47.2
#3201
1fbcbec
5.47.1
#3198
758ea26
5.47.0
#3181
738d375
5.46.1
#3192
#3191
33c62e6
5.46.0
#3187
f16b748
5.45.2
#3182
8d59e3b
5.45.1
#3172
d57698f
5.45.0
0f21c10
5.44.4
#3153
219c0db
5.44.3
#3164
d3c397f
5.44.2
#3163
5a88e47
5.44.1
#3160
d91d9f4
5.44.0
0325a39
5.43.1
#3145
0e137b2
5.43.0
#3137
#3136
83953db
5.42.0
#3098
589adb4
#3134
eec7114
#3132
c37123c
#3127
e0f02ce
5.41.9
#3108
4b619ca
5.41.8
#3126
c3269b1
#3116
db617e4
5.41.7
#3115
#3114
d4cad84
5.41.6
#3112
6a28b86
#3113
7a4b500
5.41.5
#3066
97cd2b1
5.41.4
#3096
38912fb
5.41.3
#3089
4a66933
5.41.2
#3080
024ee0f
5.41.1
#3077
#3073
1aa970c
5.41.0
#2978
5a97491
#3076
ece8532
#3052
3e990eb
5.40.5
#3074
05ea32b
5.40.4
#3071
3e649f7
5.40.3
#3065
#3062
548cc1c
5.40.2
b970281
5.40.1
#3059
d4de2f5
5.40.0
9f0f1ba
5.39.2
#3043
406e21c
5.39.1
#3036
21e8495
5.39.0
#3033
a1571ea
5.38.0
6d829fc
e728299
5.37.0
078ae9d
5.36.0
#3018
ad5c07c
5.35.1
0f07467
5.35.0
dcc3b06
5.34.10
#3010
#3009
95edb40
5.34.9
#3001
4ea35dd
5.34.8
#2997
9be28a0
5.34.7
#2993
95718e8
5.34.6
#2991
e8cdb99
5.34.5
#2975
8bb27ea
5.34.4
#2979
c0a6bcd
5.34.3
#2967
#2962
52b0e34
5.34.2
4360572
5.34.1
9917df1
af75315
5.34.0
#2946
6514c33
5.33.1
#2960
b5fa6a3
5.33.0
#2958
c19c914
5.32.0
#2956
#2875
5b005cd
5.31.2
#2952
544fc7c
5.31.1
#2950
3402bfe
5.31.0
#2929
#2875
cb99080
5.30.1
#2947
#2229
85f6f6f
5.30.0
#2943
#2940
b56c3b4
#2945
38820dc
5.29.1
#2923
14ca7f4
5.29.0
09f2571
5.28.2
#2920
34c2348
5.28.1
#2917
5fbb075
5.28.0
72ea950
5.27.0
#2896
db84ad5
#2806
ff70613
#2904
#2842
1759c8b
5.26.2
c417a23
5.26.1
f2495e5
5.26.0
#2905
c9531ec
5.25.6
022f7b7
5.25.5
#2851
9391cc2
5.25.4
f69cfbc
5.25.3
#2887
b955340
5.25.2
#2883
#2880
52f6317
5.25.1
#2884
411ccae
5.25.0
#2844
5eb03cd
5.24.0
#2879
5ed154b
5.23.1
#2882
#2747
4d2136c
5.23.0
#2877
#2875
956d98c
5.22.0
#2721
273b574
5.21.2
b4e25c1
5.21.1
9ef865c
5.21.0
b7dd925
5.20.1
fe73f6d
5.20.0
#2822
3a4781b
5.19.1
#2815
#2813
a384d92
5.19.0
ed047f7
5.18.0
#2804
9abec3d
5.17.1
25bbaa8
5.17.0
#2800
6babb9e
#2796
0a4982d
5.16.0
dd6b6b2
5.15.0
#2795
f7a4292
5.14.0
#2791
#1555
6a1f7a9
5.13.2
#2778
6a851c1
5.13.1
#2746
73005e8
5.13.0
#2717
a68ead9
5.12.15
#2766
7cb670e
#2756
a8cb8a2
5.12.14
#2758
3473054
5.12.13
88029bb
5.12.12
#2719
#2718
9ef97c3
5.12.11
#2739
#2731
9c4b245
5.12.10
#2720
d51aabe
5.12.9
#2629
df74578
5.12.8
#2712
53bc9eb
5.12.7
#2711
967632c
5.12.6
#2706
#2342
de094a3
#2708
e0d3790
5.12.5
#2705
53de304
5.12.4
#2656
8468e44
5.12.3
#2702
9416501
5.12.2
#2697
#2582
f3290ac
5.12.1
#2692
#2487
509a36b
5.12.0
#2678
97fb97a
5.11.0
#2666
163ccea
5.10.4
#2676
97a297d
5.10.3
#2665
93fad41
5.10.2
#2342
f917b80
5.10.1
#2658
#2661
a6764ae
#2662
#2660
9d8f874
5.10.0
#2617
#2612
#2399
#2596
8376a9a
5.9.0
#2496
#2465
47ba055
5.8.7
#2640
b89e2e0
5.8.6
#2587
228db2c
5.8.5
#2627
#2554
00cd017
5.8.4
#2631
#2628
9f6609a
5.8.3
#2599
4dba122
5.8.2
#2609
6e99250
5.8.1
#2597
9ece15b
5.8.0
#2595
77971f4
5.7.15
#2592
238680b
5.7.14
2cf12b3
5.7.13
#2584
a053d9b
5.7.12
#2574
5bd7990
5.7.11
#2576
ca207f5
5.7.10
#2567
#2566
8158fa1
5.7.9
#2562
f87e3fe
5.7.8
782382e
5.7.7
#2543
ae7cb6c
5.7.6
#2544
#2466
9760b85
5.7.5
#2540
#2531
0140959
5.7.4
#2529
e92cea4
5.7.3
#2532
83dfb63
5.7.2
#2526
#2464
5e31eb0
5.7.1
#2515
#2466
44f7d21
5.7.0
9693321
5.6.0
5.5.4
#2512
64feec9
5.5.3
#2503
6f9ca23
5.5.2
#2506
ca68a9e
5.5.1
#2473
3e17e45
5.5.0
743c7aa
5.4.6
#2487
cce3bc3
5.4.5
#2483
3c335d4
5.4.4
#2481
51a589f
5.4.3
#2477
ab43693
5.4.2
#2452
cf13b31
5.4.1
#2455
#2450
2de15ca
5.4.0
#2435
1151022
5.3.3
91cf9a9
5.3.2
#2446
#2439
7606e36
5.3.1
#2441
1e9a13f
5.3.0
7ba2729
5.2.1
#2432
8a85207
5.2.0
#2426
c7559f4
5.1.12
#2425
#2385
1bc26a6
5.1.11
#2417
2696ef8
5.1.10
#2389
18ebee8
5.1.9
#2411
8b62d28
5.1.8
#2408
6fb6896
5.1.7
#2406
5923ed8
5.1.6
#2403
c1c2ccc
5.1.5
#2391
ca6c17a
5.1.4
#2384
4914df8
5.1.3
#2374
1813d5f
5.1.2
7ae0953
5.1.1
#2350
888dcc2
5.1.0
#1824
8ea0e1f
5.0.0
6491a18
#2203
0e88e4f
73cf5fc
0bac0fb
#2335
1867dd1
#2312
84015ff
Better Queue Markers
BullMQ v5 Migration Notes