v4
Last updated
Was this helpful?
Last updated
Was this helpful?
proper way to get version ()
use versions for lua commands ()
queue: add version support ()
sandbox: support URL (local files) as processor file ()
queue: add removeDeprecatedPriorityKey method
priority: priority is separeted in its own zset, no duplication needed
job: change job method name update to updateData
queue: add a paginated getDependencies () ()
flows: update constructor and methods to match queue base () ()
sandboxed: better compatibility with esbuild ()
child-processor: preserve dynamic imports in commonjs ()
flows: add meta key to queues created with flows ()
sandboxes: use the more compatible dynamic import instead of require ()
repeat-strategy: add missing Promise return type () ()
update-progress: remove old updateProgress script to prevent conflict () (python) ()
worker: get dirname by using module.filename () fixes ()
worker: should cap update progress events ()
worker: do not wait for slow jobs fixes ()
worker: better handling of concurrency when fetching jobs () ()
utils: use EventEmitter as a type instead of a namespace () ()
job: set delay value on current job instance when it is retried () (python) ()
connection: better handling of attached listeners ()
connection: move redis instance check to queue base ()
queue: improve clean to work iteratively () ()
update delay job property when moving to delayed set () ()
add-job: trim events when waiting-children event is published () (python) ()
worker: keep extending locks while closing workers () ()
redis-connection: check redis version greater or equal than v6 only once () ()
sandbox: do not return empty object result when it is undefined () ()
events: trim events when removing jobs () (python) ()
events: do not publish removed event on non-existent jobs () ()
events: trim events when retrying a job () ()
sandbox: update progress value on job instance () fixes ()
delayed: trim events when moving jobs to delayed (python) () ()
expose addJobLog and updateJobProgress to the Queue instance () ()
queue: batched unpack now uses range () ()
worker: forward skipVersionCheck to blockingConnection () ref ()
worker: throw exception with NaN as concurrency () ()
queue: differentiate score purpose per state in clean method () fixes ()
sandbox: convert wrapJob method as protected for extension () ()
move-to-finished: consider addition of prioritized jobs when processing last active job () (python) ()
remove: change error message when job is locked (python) () ()
connection: provide skipVersionCheck option for shared connections () ref ()
sandbox: emulate moveToDelayed method () ref ()
sandbox: ignore extra params on processor () ()
worker: abort rate-limit delay when closing worker ()
queue: throw error when name is not provided () ()
rate-limit: get pttl only if needed () ()
queue: add getRateLimitTtl method () ()
job: generate priority limit constant once () ()
retry: compare prev state instead of regex expression () ()
queue: add promoteJobs to promote all delayed jobs ()
job: add option for removing children in remove method (python) () ()
job: add removeDependencyOnFailure option () ()
worker: add id as part of token () ()
flow: emit delayed event when parent is moved to delayed () ()
common: add option to change repeatable jobs redis key hash algorithm () ()
queue: add getPrioritized and getPrioritizedCount methods () ()
priority: add prioritized as a new state () (python) ()
ref