bunqueue v2.7.17
blog · release
bunqueue v2.7.17
Fixes 2 bugs. Created job has wrong priority / options not reflected in TCP mode (#88): await queue.add(name, data, { priority: 10 }) returned job.priority === 0 over TCP.
To install bunqueue v2.7.17
Section titled “To install bunqueue v2.7.17”bun add bunqueue@2.7.17npm install bunqueue@2.7.17To upgrade bunqueue
Section titled “To upgrade bunqueue”bun add bunqueue@latestChanges
Section titled “Changes”- TCP job payloads now omit
undefined-valued keys, keeping large bulk frames compact (a 1000-job bulk payload dropped from ~446 KB to ~320 KB), which also avoids an intermittent large-frame delivery stall under load.
Bugfixes
Section titled “Bugfixes”- Created job has wrong priority / options not reflected in TCP mode (#88):
await queue.add(name, data, { priority: 10 })returnedjob.priority === 0over TCP. The Job object returned byadd()/addBulk()(andgetJob()/getJobs()) is built client-side bycreateJobProxy/createSimpleJob, which hardcodedpriority: 0,delay: 0,opts: {}. These now reflect the requested/stored options (priority,delay,opts). Embeddedadd()was already correct (it usestoPublicJob). - TCP
add()silently dropped job options: the single-job TCPPUSHpath forwarded only a subset of options, sodeduplication,ttl,tags,groupId,lifo,keepLogs,sizeLimit,stackTraceLimit,debounce,dependsOn,failParentOnFailure,removeDependencyOnFailure,continueParentOnFailure,ignoreDependencyOnFailureandtimestampwere ignored when adding a single job over TCP. ThePUSHcommand and its handler now carry and apply the full option set, matching embedded mode and bulk add.addBulkforwarding gaps (removeOnComplete/removeOnFail, parent, dedup, tags, groupId, dependsOn) were closed too.
getJobsAsync()returns a slimopts({}) for listed jobs, whereasgetJob()returns the fullopts. The reflecteddelaytracks current scheduling (runAt - createdAt), so after a retry/backoff it reflects the next run, not the originally requested delay.
Thanks to 1 contributor!
Section titled “Thanks to 1 contributor!”← bunqueue v2.7.16 · Release on GitHub · Commits since v2.7.16 · Full changelog · All posts