Comparing version 5.35.1 to 5.36.0
@@ -145,3 +145,3 @@ "use strict"; | ||
if (jobData) { | ||
return Object.assign(Object.assign({ key, name: jobData.name, endDate: parseInt(jobData.endDate) || null, tz: jobData.tz || null, pattern: jobData.pattern || null, every: jobData.every || null }, (jobData.data || jobData.opts | ||
return Object.assign(Object.assign({ key, iterationCount: parseInt(jobData.ic) || null, name: jobData.name, endDate: parseInt(jobData.endDate) || null, tz: jobData.tz || null, pattern: jobData.pattern || null, every: jobData.every || null }, (jobData.data || jobData.opts | ||
? { | ||
@@ -148,0 +148,0 @@ template: this.getTemplateFromJSON(jobData.data, jobData.opts), |
@@ -328,3 +328,3 @@ "use strict"; | ||
end | ||
rcall("HMSET", schedulerKey, "name", opts['name'], | ||
rcall("HMSET", schedulerKey, "name", opts['name'], "ic", 1, | ||
unpack(optionalValues)) | ||
@@ -331,0 +331,0 @@ end |
@@ -151,2 +151,3 @@ "use strict"; | ||
rcall("ZADD", repeatKey, nextMillis, jobSchedulerId) | ||
rcall("HINCRBY", schedulerKey, "ic", 1) | ||
local eventsKey = KEYS[5] | ||
@@ -153,0 +154,0 @@ local metaKey = KEYS[2] |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.version = void 0; | ||
exports.version = '5.35.1'; | ||
exports.version = '5.36.0'; | ||
//# sourceMappingURL=version.js.map |
@@ -142,3 +142,3 @@ import { __rest } from "tslib"; | ||
if (jobData) { | ||
return Object.assign(Object.assign({ key, name: jobData.name, endDate: parseInt(jobData.endDate) || null, tz: jobData.tz || null, pattern: jobData.pattern || null, every: jobData.every || null }, (jobData.data || jobData.opts | ||
return Object.assign(Object.assign({ key, iterationCount: parseInt(jobData.ic) || null, name: jobData.name, endDate: parseInt(jobData.endDate) || null, tz: jobData.tz || null, pattern: jobData.pattern || null, every: jobData.every || null }, (jobData.data || jobData.opts | ||
? { | ||
@@ -145,0 +145,0 @@ template: this.getTemplateFromJSON(jobData.data, jobData.opts), |
@@ -10,2 +10,3 @@ import { JobSchedulerTemplateOptions } from '../types'; | ||
id?: string | null; | ||
iterationCount?: number; | ||
endDate: number | null; | ||
@@ -12,0 +13,0 @@ tz: string | null; |
@@ -325,3 +325,3 @@ const content = `--[[ | ||
end | ||
rcall("HMSET", schedulerKey, "name", opts['name'], | ||
rcall("HMSET", schedulerKey, "name", opts['name'], "ic", 1, | ||
unpack(optionalValues)) | ||
@@ -328,0 +328,0 @@ end |
@@ -148,2 +148,3 @@ const content = `--[[ | ||
rcall("ZADD", repeatKey, nextMillis, jobSchedulerId) | ||
rcall("HINCRBY", schedulerKey, "ic", 1) | ||
local eventsKey = KEYS[5] | ||
@@ -150,0 +151,0 @@ local metaKey = KEYS[2] |
@@ -1,1 +0,1 @@ | ||
export declare const version = "5.35.1"; | ||
export declare const version = "5.36.0"; |
@@ -1,2 +0,2 @@ | ||
export const version = '5.35.1'; | ||
export const version = '5.36.0'; | ||
//# sourceMappingURL=version.js.map |
{ | ||
"name": "bullmq", | ||
"version": "5.35.1", | ||
"version": "5.36.0", | ||
"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
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
1950442
31429