node-resque
Advanced tools
Comparing version 7.0.1 to 7.0.2
@@ -173,2 +173,3 @@ "use strict"; | ||
await this.connection.redis.watch(key); | ||
await this.connection.redis.watch(this.connection.key("delayed_queue_schedule")); | ||
const length = await this.connection.redis.llen(key); | ||
@@ -175,0 +176,0 @@ if (length === 0) { |
@@ -6,3 +6,3 @@ { | ||
"license": "Apache-2.0", | ||
"version": "7.0.1", | ||
"version": "7.0.2", | ||
"homepage": "http://github.com/actionhero/node-resque", | ||
@@ -33,5 +33,5 @@ "repository": { | ||
"devDependencies": { | ||
"@types/ioredis": "^4.14.7", | ||
"@types/jest": "^25.1.3", | ||
"@types/node": "^13.7.4", | ||
"@types/ioredis": "^4.14.9", | ||
"@types/jest": "^25.1.4", | ||
"@types/node": "^13.9.1", | ||
"jest": "^25.1.0", | ||
@@ -42,4 +42,4 @@ "node-schedule": "^1.3.2", | ||
"ts-node": "^8.6.2", | ||
"typedoc": "^0.16.10", | ||
"typescript": "^3.7.5" | ||
"typedoc": "^0.17.0", | ||
"typescript": "^3.8.3" | ||
}, | ||
@@ -46,0 +46,0 @@ "jest": { |
@@ -271,2 +271,5 @@ // To read notes about the leader locking scheme, check out: | ||
await this.connection.redis.watch(key); | ||
await this.connection.redis.watch( | ||
this.connection.key("delayed_queue_schedule") | ||
); | ||
const length = await this.connection.redis.llen(key); | ||
@@ -273,0 +276,0 @@ if (length === 0) { |
Sorry, the diff of this file is not supported yet
652696
7814