Comparing version 5.7.12 to 5.7.13
@@ -120,5 +120,5 @@ "use strict"; | ||
const jobInstances = jobs.map(job => { var _a; return new this(queue, job.name, job.data, job.opts, (_a = job.opts) === null || _a === void 0 ? void 0 : _a.jobId); }); | ||
const multi = client.multi(); | ||
const pipeline = client.pipeline(); | ||
for (const job of jobInstances) { | ||
job.addJob(multi, { | ||
job.addJob(pipeline, { | ||
parentKey: job.parentKey, | ||
@@ -130,3 +130,3 @@ parentDependenciesKey: job.parentKey | ||
} | ||
const results = (await multi.exec()); | ||
const results = (await pipeline.exec()); | ||
for (let index = 0; index < results.length; ++index) { | ||
@@ -133,0 +133,0 @@ const [err, id] = results[index]; |
@@ -645,7 +645,7 @@ "use strict"; | ||
try { | ||
const multi = (await this.client).multi(); | ||
const pipeline = (await this.client).pipeline(); | ||
for (const job of jobs) { | ||
await this.scripts.extendLock(job.id, job.token, this.opts.lockDuration, multi); | ||
await this.scripts.extendLock(job.id, job.token, this.opts.lockDuration, pipeline); | ||
} | ||
const result = (await multi.exec()); | ||
const result = (await pipeline.exec()); | ||
for (const [err, jobId] of result) { | ||
@@ -652,0 +652,0 @@ if (err) { |
@@ -117,5 +117,5 @@ import { __rest } from "tslib"; | ||
const jobInstances = jobs.map(job => { var _a; return new this(queue, job.name, job.data, job.opts, (_a = job.opts) === null || _a === void 0 ? void 0 : _a.jobId); }); | ||
const multi = client.multi(); | ||
const pipeline = client.pipeline(); | ||
for (const job of jobInstances) { | ||
job.addJob(multi, { | ||
job.addJob(pipeline, { | ||
parentKey: job.parentKey, | ||
@@ -127,3 +127,3 @@ parentDependenciesKey: job.parentKey | ||
} | ||
const results = (await multi.exec()); | ||
const results = (await pipeline.exec()); | ||
for (let index = 0; index < results.length; ++index) { | ||
@@ -130,0 +130,0 @@ const [err, id] = results[index]; |
@@ -642,7 +642,7 @@ import * as fs from 'fs'; | ||
try { | ||
const multi = (await this.client).multi(); | ||
const pipeline = (await this.client).pipeline(); | ||
for (const job of jobs) { | ||
await this.scripts.extendLock(job.id, job.token, this.opts.lockDuration, multi); | ||
await this.scripts.extendLock(job.id, job.token, this.opts.lockDuration, pipeline); | ||
} | ||
const result = (await multi.exec()); | ||
const result = (await pipeline.exec()); | ||
for (const [err, jobId] of result) { | ||
@@ -649,0 +649,0 @@ if (err) { |
{ | ||
"name": "bullmq", | ||
"version": "5.7.12", | ||
"version": "5.7.13", | ||
"description": "Queue for messages and jobs based on Redis", | ||
@@ -5,0 +5,0 @@ "homepage": "https://bullmq.io/", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1508593