v1
Last updated
Was this helpful?
Last updated
Was this helpful?
drain: consider empty active list () ()
sandbox: support update method () ()
script-loader: use cache to read script once () ()
add-job: handle parent split on js () ()
Removed humans, they weren't doing fine with animals.
Animals are now super cute, all of them.
Introduced animals into the world, we believe they're going to be a neat addition.
repeat: allow passing a cron strategy () ref ()
job: update delay when changeDelay () fixes ()
revert "chore: allow esm imports through exports field" () ()
job: expose delay in instance () ()
revert "feat(sandbox): experimental support ESM" () ()
fix husky install ()
clean: consider priority when cleaning waiting jobs () ()
parent-priority-check: use tonumber on priority () ()
sandbox: experimental support ESM ()
move-parent-to-wait: emit waiting instead of active event () ()
job: declare discarded as protected () ()
flow: consider priority when parent is moved () ()
clean-jobs-in-set: use ZRANGEBYSCORE when limit > 0 () ()
get-flow: consider groupKey () fixes ()
promote: consider empty queue when paused () ()
sandboxed-process: consider UnrecoverableError () fixes ()
retry-jobs: consider paused queue () ()
retry-job: consider paused queue () ()
parent: emit waiting event when no pending children () ()
avoid calling delay() if queue is being closed () ()
queue: get rid of repeat options from defaultJobOptions () ()
unpack empty metrics in batches ()
repeat: save repeatJobKey reference () ()
error-prototype: define custom name for toJSON method () ()
queue: fix addBulk signature ResultType () ()
job: save finishedOn attribute on instance () ()
remove-job: send prefix key instead of jobKey () ()
worker: change the number of concurrent processes () ref ()
waiting-children: pass right timestamp value in moveToWaitingChildren () ()
flow-producer: add event listener types () ()
close: emit ioredis:close event instead of error () fixes ()
get-workers: use blockingConnection client to set clientName () fixes ()
flow-producer: easier to build extension () ()
redis-connection: save cluster opts and coerse redis version () ref fixes ()
job: add job helper attribute for extension () ()
remove-job: pass right prev param in removed event () ()
remove-repeatable: return boolean depending on job existence () ref ()
repeatable: emit removed event when removing () ()
remove-parent: check removed record from waiting-children () ()
stalled: consider removeOnFail when failing jobs () fixes ()
add-bulk: use for loop and throw if error is present () fixes ()
move-to-delayed: allow passing token () ()
job: delete token when moving to delayed () ()
queue-base: emit close error when no closing () fixes ()
queue-scheduler: apply isNotConnectionError () fixes ()
cluster: check correct Upstash host () fixes ()
job: remove Error from Promise return in moveToWaitingChildren () ()
worker: restore worker suffix to empty string () fixes ()
worker-listener: use generics in events () ref ()
connection: remove Queue reconnect overrides () ()
queue-getters: add getQueueEvents () ()
clean: consider processedOn and finishedOn attributes () ()
queue: close repeat connection when calling close () ()
cron-parser: upgrades version to 4.2.1 () fixes ()
async-send: check proc.send type () ()
trim-events: consider maxLenEvents as 0 () ()
clean: speed up clean operation using deletion marker () ()
flow: remove processed children () fixes ()
allow QueueScheduler to be extended ()
master: do not export master file () fixes ref ()
queue: sanitize job types in getJobs and getJobsCount () fixes ()
move-to-finished: avoid an extra roundtrip when using rate limit () ()
drained: emit event only once when queue has drained the waiting list () fixes ref ()
utils: fix proc.send type () fixes ()
get-waiting-children-count: consider waiting-children status only () ()
metrics: add metrics support ()
rate-limiter: move job to wait after retry when groupKey is missed () fixes ()
cluster: check for host presence in Upstash validation () fixes ()
retry-jobs: allow to retry completed jobs () ()
connection: throw error when Upstash host is provided () fixes ()
move-to-finished: increment attemptsMade when moving job to active () fixes ()
flow: respect defaultJobOptions from queue opts () fixes ()
retry-jobs: pass timestamp as option () ()
job: add prefix getter () ()
queue-getters: add getQueueSchedulers () ref ()
backoff: validate UnrecoverableError presence () ()
get-job-counts: add default values () ()
sandbox: pass parent property () ()
move-to-finished: validate lock first () ()
job: pass queueName into sandbox () fixes ref ()
clean: consider checking parent jobs when cleaning () ()
drain: delete priority queueKey () ()
remove-parent-dependency: do not emit wait event in hard deletions () ()
update: throw error when missing job key () ()
queue: add retryJobs method for failed jobs () ()
lua: call del command with multiple keys () ()
drain: consider checking parent jobs when draining () ()
repeat: consider immediately option with cron () fixes ()
retry: pass state in error message () ()
retry: delete props in retryJob lua script () ()
add support for removeOn based on time ()
job: increase attemptsMade when moving job to active () fixes ()
queue-events: add retries-exhausted event () ()
dont loop through empty modules paths () fixes ()
queue: add JobType and JobState unions for better typing () ()
queue: use 0 as initial value for getJobCountByTypes reducer () ()
worker: blockTime must be integer on older Redis ()
remove-job: consider removing parent dependency key in lua scripts () ()
sandbox: exit uncaughtException instead of throwing error ()
sanboxed-process: support .cjs files () ()
job: throw error when delay and repeat are provided together () ()
queue: add missing error event typing () ()
update-progress: throw error if job key is missing () ref ()
job: use generic types for static methods () ()
add deprecated tag in progress and Queue3 class () ()
queue: add better event typing () ()
queue: reuse generic typing for jobs ()
worker: reuse generic typing for jobs ()
queue-scheduler: add better event typing () ()
downgrade typescript to 3.9.10 fixes () ()
worker: fix undefined moveToActive ()
package: add jsnext:main prop () ()
copy lua files to correct location ()
correct dist path ()
also export bullmq as an ESM ()
worker: add better event typing () ()
move-to-active: add try catch in moveToActive call () ()
redis-connection: consider cluster redisOptions config () ()
remove debug console.error () ()
connection: check instance options to console log deprecation message () ()
add-job: save parent data as json () ()
worker: better handling of block timeout ()
queue-events: add better event typing () ()
emit drain event if no jobs left when completing ()
worker: use client for setting worker name ()
worker: make moveToActive protected ()
worker: always try to move to active after waiting for job () ()
script-loader: lua script loader with include support () ()
stalled: save finishedOn when job stalled more than allowable limit () ()
tsconfig: only include node types () ()
child-processor: add deprecation warning for progress method () ()
clean: use range values in lua script () ()
job: use this when use new operators () ()
job: change private attributes to protected for extensions () ()
load-includes: export includes to be reused in extensions () ()
queue-events: add cleaned event () ()
worker: change private attributes to protected for pro extension () ()
clean: speed up clean method when called with limit param () ()
queue: add waiting event type declaration () ()
move-to-failed: delete closing check that prevents script execution () fixes ()
flow: remove repeat option from FlowJob opts () fixes ()
commands: copy includes lua scripts () fixes ()
flow: consider continually adding jobs () fixes ()
override enableReadyCheck, maxRetriesPerRequest fixes reconnection ()
queue-base: deprecation warning on missing connection ()
queue-base: show connection deprecation warning () fixes ()
child-pool: pipe process stdout and stderr() fixes ()
properly pass sharedConnection option to worker base class ()
msgpackr: upgrade version to 1.4.6 to support esm bundlers () fixes ()
msgpack: replace msgpack by msgpackr ()
queue-getters: only getting the first 2 jobs ()
easier to build extensions on top of BullMQ ()
sandboxed-process: handle init-failed error () ()
change-delay: add current time to delay () fixes ()
obliterate: do not pass unused variables () ()
obliterate: consider dependencies and processed keys () ()
queue: add drain lua script () ()
flow-producer: use default prefix in add method () fixes ()
running: move running attribute before first async call () ()
queue-events: launch without launching process () ()
wait-for-job: add catch block and emit error () ()
connection: fail only if redis connection does not recover () ()
is-finished: reject when missing job key () fixes ()
wait-until-finished: isFinished return failedReason or returnValue () fixes ()
add-job: throw error when missing parent key () ()
queue-events: duplicate connection () fixes ()
redis-connection: improve closing fixes ()
worker: launch without launching process () (), closes
queue-scheduler: launch without launching process () (), closes
queuescheduler: handle shared connections fixes ()
worker: use spread operator in processing map keys () ()
retry: throw error when retry non failed job () ()
queue-events: add waiting-children event () ()
events: add added event when job is created () ()
protect emit calls with throw/catch ()
flows: add queuesOptions for rate limit () (), closes
flow: add bulk ()
rate-limiter: check groupKey is not undefined ()
redis-connection: add error event in waitUntilReady ()
move clientCommandMessageReg to utils ()
connection hangs with failed connection fixes ()
worker: retry with delay errors in run loop ()
move-to-finished: remove stalled jobs when finishing ()
repeatable: validate endDate when adding next repeatable job ()
connect if redis client has status "wait" ()
queue: ensure the Queue constructor doesn't try to set queue options if the client is closed ()
sandbox: use updateProgress method name ()
worker+scheduler: add a "running" attribute for healthchecking ()
reprocess: do not store job.id in added list ()
queue: add missing events typings ()
stalled-jobs: move stalled jobs to wait in batches (), closes
job: add changeDelay method for delayed jobs ()
worker: change active event typing ()
queue-events: fix drained typing ()
worker: add active event typing ()
worker: add progress event typing ()
worker: add drained event typing ()
worker: await for processing functions ()
redis-connection: remove error event listener from client ()
job: expose queueName ()
job: destructure default opts for pagination ()
job: add getDependenciesCount method ()
flow-producer: add getFlow method ()
worker: remove processed key when removeOnComplete ()
job: extend getDependencies to support pagination ()
job: parse results in getDependencies for processed jobs ()
move-to-waiting-children: make opts optional ()
add some event typing ()
move-stalled-jobs-to-wait: send failedReason to queueEvents ()
add move to waiting children for manual processing () ()
obliterate: remove job logs ()
get-workers: use strict equality on name fixes ()
flow-producer: expose client connection ()
repeat: add immediately opt for repeat ()
movetofinished: use parent queue for events ()
removejob: delete processed hash ()
ensure connection reconnects when pausing fixes ()
getjoblogs: no reversed pagination ()
flow-producer: use custom jobId as parentId for children fixes ()
custombackoff: provide job as third parameter ()
flow-producer: process parent with children as empty array fixes ()
addbulk: should not consider repeat option ()
job: add sizeLimit option when creating a job ()
deps: upgrading lodash to 4.17.21 ()
cluster: add redis cluster support ()
redisclient: not reference types from import ()
sandbox: properly redirect stdout () ()
sandbox: handle broken processor files ()
queueevents: add active type fixes ()
add option for non-blocking getNextJob ()
add return type for job.waitUntilFinished() ()
job: pass parent opts to addBulk ()
add missing Redis Cluster types fixes ()
addjob: fix redis cluster CROSSSLOT ()
jobcreate: allow passing parent in job.create ()
add typing for addNextRepeatableJob ()
movetocompleted: should not complete before children ()
obliterate: correctly remove many jobs ()
remove internal deps on barrel fixes () ()
flows: correct typings fixes ()
movetodelayed: check if job is in active state ()
worker: make token optional in processor function fixes ()
worker: passing token in processor function ()
movetocompleted: throw an error if job is not in active state ()
worker: close base class connection ()
remove repeatable with obliterate ()
add workerDelay option to limiter ()
add parentKey property to Job ()
rename Flow to FlowProducer class ()
add remove support for flows ()
job: consider waiting-children state ()
read lua scripts serially ()
flow: relative dependency path fixes ()
add support for flows (parent-child dependencies) () ()
obliterate: safer implementation ()
add method to "obliterate" a queue, fixes ()
specify promise type to make TS 4.1 and 4.2 happy. () ()
remove "client" property of QueueBaseOptions () ()
remove next job in removeRepeatableByKey fixes ()
add jobId support to repeatable jobs fixes ()
reconnect at start fixes ()
worker: avoid possible infinite loop fixes ()
improve job timeout notification by giving the job name and id in the error message () ()
job finish queue events race condition ()
job: expose extendLock as a public method ()
add support for manually processing jobs fixes ()
correctly handle "falsy" data values fixes ()
worker: setname on worker blocking connection ()
catch errors from Repeat () ()
correctly handle "falsy" data values fixes ()
add ability to get if queue is paused or not ()
promote jobs to the right "list" when paused ()
clientCommandMessageReg to support GCP memorystore v5 ()
add generic type to processor ()
add name and return types to queue, worker and processor ()
job: remove listeners before resolving promise ()
worker: continue processing if handleFailed fails. fixes ()
worker: fix memory leak on Promise.race () ()
worker: setname on worker blocking connection () ()
remove async for loop in child pool fixes ()
sandbox: kill child workers gracefully () ()
add grouped rate limiting ()
typescript: fix typings, upgrade ioredis dependencies () ()
worker: return this.closing when calling close ()
redis-connection: run the load command for reused redis client ()
remove unused options ()
scheduler: remove unnecessary division by 4096 ()
scheduler: divide timestamp by 4096 in update set fixes ()
scheduler: divide next timestamp by 4096 () ()
queue-base: error event is passed through ()
redis-connection: error event is passed through ()
worker: error event is passed through ()
worker: do not use global child pool fixes ()
workers: do not call super.close() ()
make sure closing is returned in every close call ()
scheduler: duplicate connections fixes ()
worker: return this.closing when calling close ()
removed deprecated and unused node-uuid ()
job: added nullable/optional properties ()
sandbox: If the child process is killed, remove it from the pool. ()
restore the Job timestamp when deserializing JSON data () () ()
modified imports to work when esModuleInterop is disabled () ()
cleanup signatures for queue add and addBulk () ()
exit code 12 when using inspect with child process () ()
types: add sandboxed job processor types () ()
made queue name publicly readable for ()
modified QueueGetters.getJob and Job.fromId to also return null to ()
modified QueueGetters.getJob and Job.fromId to return undefined ()
don't fail a job when the worker already lost the lock ()
remove duplicate active entry ()
get rid of flushdb/flushall in tests ()
delete logs when cleaning jobs in set ()
add tslib dependency fixes ()
change default QueueEvents lastEventId to $ ()
ensure QE ready before adding test events ()
explicitly test the behavior of .on and .once ()
check of existing redis instance ()
add generic type to job data and return value ()
remove delay dependency ()
remove dependence on Bluebird.delay ()
check in moveToFinished to use default val for opts.maxLenEvents ()
avoid Job<->Queue circular json error ()
avoid the .toJSON serializer interface ()
default job settings ()
job.progress() return last progress for sandboxed processors ()
test worker extends job lock while job is active ()
only run coveralls after success ()
added code coverage and coveralls ()
added missing deps for coverage ()
ignore commitlint file in coverage ()
only upload coverage once after all tests pass ()
failing build ()
fix failing tests ()
initial version of job locking mechanism ()
save job stacktrace on failure ()
simplify logic for stackTraceLimit ()
add compilation step before running tests ()
add extra client to worker fixes ()
add missing dependency ()
check closing after resuming from pause ()
default opts ()
do not block if blockTime is zero ()
do not exec if closing ()
do not trim if maxEvents is undefined ()
emit wait event in add job ()
fix a couple of job tests ()
fix compiling error ()
fix more tests ()
fix progress script ()
fix retry functionality ()
fix several floating promises ()
fixed reprocess lua script ()
improve concurrency mechanism ()
improve disconnection for queue events ()
initialize events comsumption in constructor ()
make ioredis typings a normal dependency ()
minor fixes ()
parse progres and return value in events ()
properly emit event for progress ()
reduce drain delay to 5 seconds ()
remove buggy close() on redis-connection (fixes 5 failing tests) ()
remove unused dependencies ()
replace init by waitUntilReady ()
reworked initialization of redis clients ()
several fixes to make the lib work on other ts projects ()
throw error messages instead of codes ()
update tests after merge ()
wait until ready before trying to get jobs ()
connections: reused connections ()
waitUntilFinished improvements ()
add cleaned event ()
add empty method ()
add retry errors ()
add script to generate typedocs ()
add some new tests for compat class, more minor fixes ()
add support for adding jobs in bulk ()
add trimEvents method to queue client ()
automatically trim events ()
emit global stalled event fixes ()
get rid of Job3 in favor of bullmq Job class ()
implement close in redis connection fixes ()
make delay in backoffs optional ()
move async initialization to constructors ()
port a lot of functionality from bull 3.x ()
port more features from bull 3.x ()
ported tests and functionality from bull 3 ()
workers: support for async backoffs ()
remove support of bull3 config format in compat class ()
support global:progress event ()
trim option to event stream & fix ()